資訊專欄INFORMATION COLUMN
摘要：類提供了一個可擴(kuò)展的線程池實(shí)現(xiàn)。使用舉例這里有一個網(wǎng)絡(luò)服務(wù)，其中一個線程池中的線程為請求提供服務(wù)。因此返回的中的每個都是完成狀態(tài)。執(zhí)行給定的一組任務(wù)，如果其中一個任務(wù)成功完成沒有拋出異常則返回。
Executor
Executor是java.util.concurrent包中的一個接口，是一個執(zhí)行提交的Runnable任務(wù)的對象。這個接口提供了一種方式把任務(wù)提交從每個任務(wù)會如何執(zhí)行的方法中解耦，包括線城市用，調(diào)度等的細(xì)節(jié)。使用Executor代替了顯式創(chuàng)建線程。例如，比起對一組task中的每一個調(diào)用new Thread(new(RunnableTask())).start()，你可以用：
Executor executor = anExecutor; executor.execute(new RunnableTask1()); executor.execute(new RunnableTask2()); ...
但是，Executor接口不是嚴(yán)格需要執(zhí)行是異步的。在最簡單的情況中，一個executor能夠在調(diào)用者的線程上立即運(yùn)行提交的任務(wù)：
class DirectExecutor implements Executor {
public void execute(Runnable r) {
r.run();
}
}
更典型的是，任務(wù)執(zhí)行在非調(diào)用者線程。下面的executor為每個task產(chǎn)出一個新的線程：
class ThreadPerTaskExecutor implements Executor {
public void execute(Runnable r) {
new Thread(r).start();
}
}
很多Executor的實(shí)現(xiàn)強(qiáng)制加入了一些關(guān)于如何以及何時任務(wù)被調(diào)度的限制。下面的executor串行提交的任務(wù)到第二個executor，表明它是一個混合的executor：
class SerialExecutor implements Executor {
final Queue tasks = new ArrayDeque();
final Executor executor;
Runnable active;
SerialExecutor(Executor executor) {
this.executor = executor;
}
public synchronized void execute(final Runnable r) {
tasks.offer(new Runnable() {
public void run() {
try {
r.run();
} finally {
scheduleNext();
}
}
});
if (active == null) {
scheduleNext();
}
}
protected synchronized void scheduleNext() {
if ((active = tasks.poll()) != null) {
executor.execute(active);
}
}
}
在java.util.concurrent包中提供的Executor接口的實(shí)現(xiàn)（如ThreadPoolExecutor，ScheduledThreadPoolExecutor，ForkJoinPool，AbstractExecutorService）也同時實(shí)現(xiàn)了ExecutorService，這是一個更廣泛的接口。ThreadPoolExecutor類提供了一個可擴(kuò)展的線程池實(shí)現(xiàn)。Executors類為這些Executors提供了方便的工廠方法。
內(nèi)存一致性效應(yīng)：線程中在提交一個Runnable對象給一個Executor之前發(fā)生的操作happen-before執(zhí)行這個Runnable（可能在另一個線程中執(zhí)行）。
實(shí)現(xiàn)Executor接口需要實(shí)現(xiàn)execute方法，定義如下：
void execute(Runnbale command)
這個方法在未來某個時間點(diǎn)執(zhí)行給定的command。這個command可能執(zhí)行在一個新的線程中，在一個池化的線程中，或在調(diào)用者線程中，這取決于Executor的實(shí)現(xiàn)。
ExecutorServiceExecutorService接口繼承Executor接口，是提供管理終止的方法以及produce出Future去跟蹤一個或多個異步任務(wù)進(jìn)度的方法的Executor。
一個ExecutorService可以被shutdown，會導(dǎo)致它拒絕新的tasks。提供了兩個不同的方法去關(guān)閉一個ExecutorService。shutdown方法允許之前提交的任務(wù)在終止之前執(zhí)行，shutdownNow方法禁止等待已經(jīng)開始任務(wù)并試圖結(jié)束正在執(zhí)行的任務(wù)。如果一個ExecutorService終止了，一個executor沒有正在執(zhí)行的活躍任務(wù)，沒有等待執(zhí)行的任務(wù)，也沒有新任務(wù)能被提交。一個沒有使用的ExecutorService應(yīng)該被關(guān)閉以回收資源。
submit方法根據(jù)Executor的execute(Runnable)方法擴(kuò)展，創(chuàng)建并返回一個Future，能夠用來cancel執(zhí)行以及等待執(zhí)行完成。invokeAny方法以及invokeAll方法執(zhí)行最普通的批量執(zhí)行，執(zhí)行一組任務(wù)然后等待至少一個，或者所有任務(wù)完成。
Executors類為ExecutorService提供工廠方法。
使用舉例這里有一個網(wǎng)絡(luò)服務(wù)，其中一個線程池中的線程為請求提供服務(wù)。它使用預(yù)配置的Executors的newFixedThreadPool工廠方法：
class NetworkService implements Runnable {
private final ServerSocket serverSocket;
private final ExecutorService pool;
public NetworkService(int port, int poolSize)
throws IOException {
serverSocket = new ServerSocket(port);
pool = Executors.newFixedTreadPool(poolSize);
}
public void run() { // run the service
try {
for (;;) {
pool.execute(new Handler(serverSocket.accept()));
}
} catch (IOException ex) {
pool.shutdown();
}
}
}
class Handler implements Runnable {
private final Socket socket;
Handler(Socket socket) { this.socket = socket; }
public void run() {
// read and service request on socket
}
}
下面的方法哦通過兩步關(guān)閉一個ExecutorService，首先調(diào)用shutdown以拒絕新來的tasks，然后調(diào)用shutdownNow（如果有必要的話），去cancel任何執(zhí)行的任務(wù)：
void shutdownAndAwaitTermination(ExecutorService pool) {
pool.shutdown(); // Disable new tasks from being submitted
try {
// Wait a while for existing tasks to terminate
if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
pool.shutdownNow(); // Cancel currently executing tasks
// Wait a while for tasks to respond to being cancelled
if (!pool.awaitTermination(60, TimeUnit.SECONDS))
System.err.println("Pool did not terminate");
}
} catch (InterruptedException ie) {
// (Re-)Cancel if current thread also interrupted
pool.shutdownNow();
// Preserve interrupt status
Thread.currentThread.interrupt();
}
}
ExecutorService中定義的方法
shutdown
void shutdown()
啟動有序關(guān)閉，執(zhí)行先前提交的任務(wù)，但是不接受新的任務(wù)。如果已經(jīng)關(guān)閉再次執(zhí)行沒有影響。
這個方法不等待先前提交的任務(wù)完成執(zhí)行，使用awaitTermination去等待任務(wù)執(zhí)行完畢。
shutdownNowListshutdownNow()
試圖停止所有正在執(zhí)行的任務(wù)，停止等待任務(wù)的處理，返回一個等待執(zhí)行的任務(wù)列表。
這個方法不等待正在執(zhí)行的任務(wù)終止，使用awaitTermination去等待任務(wù)終止。
盡力（best-effort）去停止正在執(zhí)行的任務(wù)。例如，標(biāo)準(zhǔn)實(shí)現(xiàn)會通過Thread的interrupt去cancel任務(wù)，因此任何回應(yīng)終止失敗的任務(wù)永遠(yuǎn)不會終止。
isShutdownboolean isShutdown()
如果executor已經(jīng)被shutdown則返回true。
isTerminatedboolean isTerminated()
如果所有任務(wù)在shutdown之后都執(zhí)行完成則返回true。注意isTerminated永遠(yuǎn)不會為true除非shutdown或shutdownNow先執(zhí)行。
awaitTerminationboolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException
在一個shutdown請求后阻塞直到所有任務(wù)完成執(zhí)行，或者timeout發(fā)生，或者當(dāng)前線程被interrupt，看哪個先發(fā)生。
submitFuture submit(Callable task)
提交一個返回值的任務(wù)去執(zhí)行并返回一個代表任務(wù)掛起結(jié)果的Future對象。Future的get方法會返回成功完成的任務(wù)結(jié)果。
如果你想要立即阻塞等待一個任務(wù)完成，你可以使用result = exec.submit(aCallable).get()。
submitFuture submit(Runnable task, T result)
提交一個Runnable任務(wù)去執(zhí)行并返回一個代表這個任務(wù)的Future。Future的get方法會返回成功完成的任務(wù)結(jié)果。
submitFuture submit(Runnable task)
提交一個Runnable任務(wù)去執(zhí)行并返回一個代表這個任務(wù)的Future。Future的get方法會返回成功完成的任務(wù)結(jié)果null。
invokeAll
