使用SPRING中的執行緒池ThreadPoolTaskExecutor並且得到任務執行的結果
XML配置
<bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!-- 核心執行緒數,預設為1 --> <property name="corePoolSize" value="10" /> <!-- 最大執行緒數,預設為Integer.MAX_VALUE --> <property name="maxPoolSize" value="50" /> <!-- 佇列最大長度,一般需要設定值>=notifyScheduledMainExecutor.maxNum;預設為Integer.MAX_VALUE <property name="queueCapacity" value="1000" /> --> <!-- 執行緒池維護執行緒所允許的空閒時間,預設為60s --> <property name="keepAliveSeconds" value="300" /> <!-- 執行緒池對拒絕任務(無執行緒可用)的處理策略,目前只支援AbortPolicy、CallerRunsPolicy;預設為後者 --> <property name="rejectedExecutionHandler"> <!-- AbortPolicy:直接丟擲java.util.concurrent.RejectedExecutionException異常 --> <!-- CallerRunsPolicy:主執行緒直接執行該任務,執行完之後嘗試新增下一個任務到執行緒池中,可以有效降低向執行緒池內新增任務的速度 --> <!-- DiscardOldestPolicy:拋棄舊的任務、暫不支援;會導致被丟棄的任務無法再次被執行 --> <!-- DiscardPolicy:拋棄當前任務、暫不支援;會導致被丟棄的任務無法再次被執行 --> <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" /> </property> </bean>
<span style="color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;">用ThreadPoolExecutor的時候,又想知道被執行的任務的執行情況,這時就可以用FutureTask。</span><br style="font-size: 13px; color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; line-height: 20px;" /><span style="color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;">ThreadPoolTask</span>
<span style="color: rgb(119, 119, 119); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;"></span><pre name="code" class="java">package com.zuidaima.threadpool; import java.io.Serializable; import java.util.concurrent.Callable; public class ThreadPoolTask implements Callable<String>, Serializable { private static final long serialVersionUID = 0; // 儲存任務所需要的資料 private Object threadPoolTaskData; private static int consumeTaskSleepTime = 2000; public ThreadPoolTask(Object tasks) { this.threadPoolTaskData = tasks; } public synchronized String call() throws Exception { // 處理一個任務,這裡的處理方式太簡單了,僅僅是一個列印語句 System.out.println("開始執行任務:" + threadPoolTaskData); String result = ""; // //便於觀察,等待一段時間 try { // long r = 5/0; for (int i = 0; i < 100000000; i++) { } result = "OK"; } catch (Exception e) { e.printStackTrace(); result = "ERROR"; } threadPoolTaskData = null; return result; } }
模擬客戶端提交的執行緒
package com.zuidaima.threadpool;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
public class StartTaskThread implements Runnable {
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
private int i;
public StartTaskThread(ThreadPoolTaskExecutor threadPoolTaskExecutor, int i) {
this.threadPoolTaskExecutor = threadPoolTaskExecutor;
this.i = i;
}
@Override
public synchronized void run() {
String task = "[email protected] " + i;
System.out.println("建立任務並提交到執行緒池中:" + task);
FutureTask<String> futureTask = new FutureTask<String>(
new ThreadPoolTask(task));
threadPoolTaskExecutor.execute(futureTask);
// 在這裡可以做別的任何事情
String result = null;
try {
// 取得結果,同時設定超時執行時間為1秒。同樣可以用future.get(),不設定執行超時時間取得結果
result = futureTask.get(1000, TimeUnit.MILLISECONDS);
} catch (InterruptedException e) {
futureTask.cancel(true);
} catch (ExecutionException e) {
futureTask.cancel(true);
} catch (Exception e) {
futureTask.cancel(true);
// 超時後,進行相應處理
} finally {
System.out.println("[email protected]" + i + ":result=" + result);
}
}
}
測試類
package com.zuidaima.test;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.AbstractJUnit4SpringContextTests;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import com.zuidaima.threadpool.StartTaskThread;
@RunWith(SpringJUnit4ClassRunner.class)
// 指定的執行runner,並且把你所指定的Runner作為引數傳遞給它
@ContextConfiguration(locations = "classpath*:applicationContext.xml")
public class TestThreadPool extends AbstractJUnit4SpringContextTests {
private static int produceTaskSleepTime = 10;
private static int produceTaskMaxNumber = 1000;
@Autowired
private ThreadPoolTaskExecutor threadPoolTaskExecutor;
public ThreadPoolTaskExecutor getThreadPoolTaskExecutor() {
return threadPoolTaskExecutor;
}
public void setThreadPoolTaskExecutor(
ThreadPoolTaskExecutor threadPoolTaskExecutor) {
this.threadPoolTaskExecutor = threadPoolTaskExecutor;
}
@Test
public void testThreadPoolExecutor() {
for (int i = 1; i <= produceTaskMaxNumber; i++) {
try {
Thread.sleep(produceTaskSleepTime);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
new Thread(new StartTaskThread(threadPoolTaskExecutor, i)).start();
}
}
}
<pre name="code" class="html" style="display: inline !important;"><span style="color: rgb(51, 51, 51); font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; font-size: 13px; line-height: 20px;">原文:</span><a target=_blank href="http://www.blogjava.net/paulwong/archive/2011/12/07/365773.html" target="_blank" rel="nofollow" style="font-size: 13px; color: rgb(0, 136, 204); text-decoration: none; font-family: "Helvetica Neue", Helvetica, Arial, sans-serif; line-height: 20px;">http://www.blogjava.net/paulwong/archive/2011/12/07/365773.html</a>
相關推薦
使用SPRING中的執行緒池ThreadPoolTaskExecutor並且得到任務執行的結果
XML配置 <bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor"> <!-- 核心執行
死磕 java執行緒系列之執行緒池深入解析——普通任務執行流程
(手機橫屏看原始碼更方便) 注:java原始碼分析部分如無特殊說明均基於 java8 版本。 注:執行緒池原始碼部分如無特殊說明均指ThreadPoolExecutor類。 簡介 前面我們一起學習了Java中執行緒池的體系結構、構造方法和生命週期,本章我們一起來學習執行緒池中普通任務到底是怎麼執行的。
死磕 java執行緒系列之執行緒池深入解析——未來任務執行流程
(手機橫屏看原始碼更方便) 注:java原始碼分析部分如無特殊說明均基於 java8 版本。 注:執行緒池原始碼部分如無特殊說明均指ThreadPoolExecutor類。 簡介 前面我們一起學習了執行緒池中普通任務的執行流程,但其實執行緒池中還有一種任務,叫作未來任務(future task),使用它
死磕 java執行緒系列之執行緒池深入解析——定時任務執行流程
(手機橫屏看原始碼更方便) 注:java原始碼分析部分如無特殊說明均基於 java8 版本。 注:本文基於ScheduledThreadPoolExecutor定時執行緒池類。 簡介 前面我們一起學習了普通任務、未來任務的執行流程,今天我們再來學習一種新的任務——定時任務。 定時任務是我們經常會用到的一
2、使用SPRING中的執行緒池ThreadPoolTaskExecutor實現JAVA併發
new Thread的弊端如下:a. 每次new Thread新建物件效能差。b. 執行緒缺乏統一管理,可能無限制新建執行緒,相互之間競爭,及可能佔用過多系統資源導致宕機或oom。c. 缺乏更多功能,如定時執行、定期執行、執行緒中斷。相比new Thread,Java提供的四種執行緒池的好處在於:a
使用SPRING中的執行緒池ThreadPoolTaskExecutor實現JAVA併發
使用SPRING中的執行緒池ThreadPoolTaskExecutor實現併發。 一:不需要返回值的情況 1,初始化執行緒池 Java程式碼 ThreadPoolTaskExecutor poolTaskExecutor = new ThreadPool
1.1 Spring 執行緒池 --- ThreadPoolTaskExecutor
Spring 擅長對元件的封裝和整合, Spring-context對JDK的併發包做了功能增強。 step 1 :Spring-context.xml 中增加如下程式碼 <bean id="poolTaskExecutor" class="org.springframe
在Springboot中使用執行緒池ThreadPoolTaskExecutor
package com.markor.template.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotat
實現Spring整合執行緒池ThreadPoolTaskExecutor
在之前的專案裡面用到了執行緒池的功能,這裡記錄一下。 我們為什麼要實現執行緒池,下面是我百度查的: 在Java中,如果每當一個請求到達就建立一個新執行緒,開銷是相當大的。在實際使用中,每個請求建立新執行緒的伺服器在建立和銷燬執行緒上花費的時間和消耗的系統資源,甚至可能要比花
spring執行緒池ThreadPoolTaskExecutor與阻塞佇列BlockingQueue
一: ThreadPoolTaskExecutor是一個spring的執行緒池技術,檢視程式碼可以看到這樣一個欄位: private ThreadPoolExecutor threadPoolExecutor; 可以發現,spring的 ThreadPoolTaskExecutor是
java中執行緒池的生命週期與執行緒中斷
執行緒池生命週期包括: RUNNING:接收新的任務並處理佇列中的任務 SHUTDOWN:不接收新的任務,但是處理佇列中的任務 STOP:不接收新的任務,不處理佇列中的任務,同時中斷處理中的任務 TIDYING:所有的任務處理完成,有效的執行緒數是0 TE
執行緒池ThreadPoolTaskExecutor配置說明
一般實際開發中經常用到多執行緒,所以需要使用執行緒池了, ThreadPoolTaskExecutor通常通過XML方式配置,或者通過Executors的工廠方法進行配置。 XML方式配置程式碼如下:交給spring來管理; <bean id="taskExecutor"
執行緒池ThreadPoolExecutor分析: 執行緒池是什麼時候建立執行緒的,佇列中的任務是什麼時候取出來的?
帶著幾個問題進入原始碼分析: 執行緒池是什麼時候建立執行緒的? 任務runnable task是先放到core到maxThread之間的執行緒,還是先放到佇列? 佇列中的任務是什麼時候取出來的? 什麼時候會觸發reject策略? core到maxThread之間的執行緒什麼時候會di
java 中多執行緒池 ExecutorService shutdonw及其多執行緒執行完成判斷
1.線上程池 ExecutorService的使用過程中,主執行緒開啟了多個子執行緒,如果判斷所有子執行緒任務是否完成問題; 方法一: BusinessHandler b = new Busines
C#淺談執行緒池(中):獨立執行緒池的作用及IO執行緒池
在上一篇文章中,我們簡單討論了執行緒池的作用,以及CLR執行緒池的一些特性。不過關於執行緒池的基本概念還沒有結束,這次我們再來補充一些必要的資訊,有助於我們在程式中選擇合適的使用方式。 獨立執行緒池 上次我們討論到,在一個.NET應用程式中會有一個CLR執行緒池,可以使用Th
Java執行緒池的認識、常用執行緒池的分析
什麼是程式,什麼是程序,什麼是執行緒,他們有什麼區別? 程式是指令和資料的有序集合,其本身並沒有任何執行的含義,是一個靜態的概念。 程序是一個動態的過程,是一個活動的實體。簡單來說,一個應用程式得到執行就可以看作是一個程序。程序可以包含多個同時執行的執行緒。程序也是擁有系統
關於執行緒池工作原理,任務拒接策略有哪幾種
在ThreadPoolExecutor類中提供了四個構造方法: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 public class ThreadPoolExecutor extends 
乾貨!執行緒池+CountDownLatch,實現 多執行緒併發計算、彙總
目錄結構 抽象類:求和器 單執行緒 求和器 VS 多執行緒 求和器 1)執行緒池 多個執行緒 一起併發執行,效能很生猛 2)CountDownLatch 主執行緒 使用 latch.await() 阻塞住,直到所有 子任務 都執行完畢了
池與執行緒池 技術點 目錄 1. 執行緒池作用: 提升效能 1 2. 使用流程 1 3. 執行緒與執行緒池的監控 jvisual 1 4. 執行緒常用方法 2 5. 執行緒池相關概念 2 5.1. 佇列
池與執行緒池 技術點 目錄 1. 執行緒池作用: 提升效能 1 2. 使用流程 1 3. 執行緒與執行緒池的監控 jvisual 1 4. 執行緒常用方法 2 5. 執行緒池相關概念 2 5.1. 佇列 &n
11.執行緒的狀態,執行緒池的構造方式,執行緒池的特性
一:執行緒的狀態 (1)初始狀態 實現Runnable介面和繼承Thread可以得到一個執行緒類,new一個例項出來,執行緒就進入了初始狀態。 (2) 就緒狀態 1)就緒狀態只是說你資格執行,排程程式沒有挑選到你,你就永遠是就緒狀態。