一、java ExecutorService實現
創建ExecutorService變量
private ExecutorService executor = null
2.執行對應任務時,首先生成線程池
executor = Executors.newFixedThreadPool(線程池大小);
3.循環執行線程
for (String str : ids) {
executor.submit(new Callable<Void>() {
@Override
public Void call() throws Exception {
......;//線程執行具體內容
return null;
}
});
}
4.關閉線城池, shutdown關閉線城池,執行后程序會繼續往下進行,線城池會等待所有線程線程執行完畢后關閉。
executor.shutdown();
5.設置阻塞等待awaitTermination, awaitTermination的作用是阻塞程序往下進行,使用之后程序會在所有線程執行完畢,關閉線城池之后才可以繼續進行。但是如果超過等待時間則會拋出InterruptedException異常
try {
//設置最大阻塞時間,所有線程任務執行完成再繼續往下執行
executor.awaitTermination(1, TimeUnit.HOURS);
long endTime = System.currentTimeMillis();
} catch (InterruptedException e) {
}
例
@Service
public class DataImpl extends DataService {
//設置線城池大小
public static final int THREAD_POOL_FIX_SIZE = 100;
@Autowired
private DataDao dataDao;
//線城池服務
private ExecutorService executor = null;
public void createData(Integer totalSize, Integer pageSize) {
//由於每次線程執行完畢會關閉線城池,所以要重新獲取線城池
executor = Executors.newFixedThreadPool(THREAD_POOL_FIX_SIZE);
//多線程調用
for(List<String> id :ids){
executor.submit(new Callable<Void>() {
@Override
public Void call() throws Exception {
createData(id);
return null;
}
});
}
//關閉線城池
executor.shutdown();
try {
//設置最大阻塞時間,所有線程任務執行完成再繼續往下執行
executor.awaitTermination(24, TimeUnit.HOURS);
long endTime = System.currentTimeMillis();
logger.info("=====================結束,用時"+ (endTime-startTime) + "毫秒" );
} catch (InterruptedException e) {
logger.info("======================超時" );
}
}
private void createData(String id){
……
}
}
*注:1.Executors.newFixedThreadPool(THREAD_POOL_FIX_SIZE);要在每次調用方法的時候創建,線程全部執行完成之后shundown(),釋放所有線程,這樣可以保證執行任務時生成足夠線程,線程執行完立即釋放。
2. ExecutorService可以寫在沒個類內,單獨問此類使用,不同類之間互不干擾;也可以也成公用方法,寫成公用方法后也會變成多類(多任務共享)同Spring線城池類似。
二、Spring 配置線程池(threadPoolTaskExecutor)
corePoolSize: 線程池維護線程的最少數量
keepAliveSeconds 線程池維護線程所允許的空閑時間
maxPoolSize 線程池維護線程的最大數量
queueCapacity 線程池所使用的緩沖隊列
rejectedExecutionHandler 線程池拒絕處理策略
當一個任務通過execute(Runnable)方法欲添加到線程池時:
l 如果此時線程池中的數量小於corePoolSize,即使線程池中的線程都處於空閑狀態,也要創建新的線程來處理被添加的任務。
l 如果此時線程池中的數量等於 corePoolSize,但是緩沖隊列 workQueue未滿,那么任務被放入緩沖隊列。
l 如果此時線程池中的數量大於corePoolSize,緩沖隊列workQueue滿,並且線程池中的數量小於maximumPoolSize,建新的線程來處理被添加的任務。
l 如果此時線程池中的數量大於corePoolSize,緩沖隊列workQueue滿,並且線程池中的數量等於maximumPoolSize,那么通過 handler所指定的策略來處理此任務。也就是:處理任務的優先級為:核心線程corePoolSize、任務隊列workQueue、最大線程 maximumPoolSize,如果三者都滿了,使用handler處理被拒絕的任務。
l 當線程池中的線程數量大於 corePoolSize時,如果某線程空閑時間超過keepAliveTime,線程將被終止。這樣,線程池可以動態的調整池中的線程數。
*注:1.spring 配置的線城池(threadPoolTaskExecutor)由於是spring創建注入的,在首次使用之后,會一直保持corePoolSize個空閑線程,它只會把多余的空閑線程在keepAliveSeconds 時間之后釋放,而且線城池不能調用shutdown()方法,否則再次調用,由於線程池已經關閉,會報錯。
2. threadPoolTaskExecutor也可以在配置文件配置多個線城池,防止多有任務之間競爭,或者由於不同任務使用的線城池大小不同等情況。
三、ExecutorService與threadPoolTaskExecutor對比
---------------------
作者:黑桃K_程序猿
來源:CSDN
原文:https://blog.csdn.net/kai763253075/article/details/53033853