1.類介紹：
Executor接口提供一種將任務提交與每個任務將如何運行的機制（包括線程使用的細節、調度等）分離開來的方法。
它只有一個方法excute(Runnable command),你可以復寫此方法，讓Runnable同步或異步執行
ExecutorService是Executor的一個子接口，提供了管理線程的方法，可為跟蹤一個或多個異步任務執行狀況而生成 Future 的方法。
ThreadPoolExecutor是ExecutorService的一個實現類，它通常與Executors工廠一起使用。
下面的方法取自Executors類
public static ExecutorService newFixedThreadPool(int nThreads) {
return new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>());
}
這里面使用ThreadPoolExecutor創建一個線程數為nThreads的線程池。
類似的工廠方法還有很多，可以查看JDK
ExecutorService的常用方法：
invokeAll 執行所有任務,全部執行完畢后返回每個任務的結果(FutureList),包括每個任務的狀態
invokeAny 與上面方法的區別是，只返回一個任務成功執行結果Future
submit 提交一個Task去執行，并返回執行結果
awaitTermination 當執行線程中斷、超時，或調用了shutdown方法后，阻塞直到所有的Task都執行結束。
shutdown 關閉所有執行過的Task,并不再接收新線程
isTerminated 如果所有Task都關閉則返回True,前提是調用過shutdown或shutdownNow
2.使用示例：
a.首先定義一個輔助類SystemConstant，大致方法如下：
//初始化一個線程池
public static ExecutorService getExecutor() {
if(PROCESS_EXECUTOR == null || PROCESS_EXECUTOR.isTerminated()) {
PROCESS_EXECUTOR = Executors.newFixedThreadPool(EXECUTOR_SIZE);
}
return PV_PROCESS_EXECUTOR;
}
//定義關閉方法
public static void awaitTerminationExecutor(long timeout, TimeUnit unit) {
getExecutor().shutdown();
try {
getExecutor().awaitTermination(timeout, unit);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
b.接下來是調用：
try {
SystemConstant.getExecutor().invokeAll(SystemUtils.toCallable(
new SystemUtils.CallableHandle<IPvProcess>() {
public void handle(Process process) throws Exception {
process.processLogs(logs, statDate);
}
}, prepareProcesses), perOutOfTime, TimeUnit.HOURS);
} catch (Exception e) {
logger.error(e);
}
SystemConstant.awaitTerminationProgramExecutor(allOutOfTime, TimeUnit.HOURS);
3. 類結構圖
java.util.concurrent
Class ThreadPoolExecutor
java.lang.Object
java.util.concurrent.AbstractExecutorService
java.util.concurrent.ThreadPoolExecutor
- All Implemented Interfaces:
- Executor, ExecutorService
- Direct Known Subclasses:
- ScheduledThreadPoolExecutor