資訊專欄INFORMATION COLUMN
摘要：而中直接將任務(wù)交給運行再來看創(chuàng)建一個保存所有的結(jié)果運行任務(wù)依次取結(jié)果這里使用是為了等待運行完成，如果沒完成就會阻塞如果發(fā)生異常，則取消所有任務(wù)續(xù)線程池的原理學(xué)習(xí)二
Executor接口
如果查看jdk文檔，會發(fā)現(xiàn)java線程池都源自于這個超級接口Executor，但是這個接口本身比較簡單：
public interface Executor {
/**
在未來某個時間執(zhí)行給定的命令。該命令可能在新的線程、已入池的線程或者正調(diào)用的線程中執(zhí)行，
這由 Executor 實現(xiàn)決定。
*
* @param command the runnable task
* @throws RejectedExecutionException if this task cannot be
* accepted for execution.
* @throws NullPointerException if command is null
*/
void execute(Runnable command);
}
可以看到Executor 中只有一個execute 方法。此接口提供一種將任務(wù)提交與每個任務(wù)將如何運行的機制分離開來的方法，相比較為每個人物調(diào)用new Thread(Runnable r).start() ,我們更偏向于使用Executor （執(zhí)行器）來運行任務(wù)：
Executor executor = anExecutor; executor.execute(new RunnableTask1()); executor.execute(new RunnableTask2()); ...
實現(xiàn)一個執(zhí)行器也很簡單：
class ThreadPerTaskExecutor implements Executor {
public void execute(Runnable r) {
new Thread(r).start();
}
}
ExecutorService接口
Executor 提供的方法太少了！根本不能滿足日常所需，而從它派生下來的接口ExecutorService 則顯得更通用，畢竟它也是個Service。
public interface ExecutorService extends Executor {
void shutdown();
List shutdownNow();
boolean isShutdown();
boolean isTerminated();
boolean awaitTermination(long timeout, TimeUnit unit)
throws InterruptedException;
Future submit(Callable task);
Future submit(Runnable task, T result);
Future submit(Runnable task);
List> invokeAll(Collection> tasks)
throws InterruptedException;
T invokeAny(Collection> tasks)
throws InterruptedException, ExecutionException;
...
}
可以看到,ExecutorService 接口中包含了我們平常使用的線程池的絕大多數(shù)方法，其中的一些方法在上文已經(jīng)介紹過了。
AbstractExecutorServiceAbstractExecutorService是一個抽象類，并且實現(xiàn)了ExecutorService接口。
public abstract class AbstractExecutorService implements ExecutorService
在這個類中，提供了ExecutorService 一些方法的默認實現(xiàn)，比如submit ，invokeAll ，首先看submit 的實現(xiàn)：
publicFuture submit(Callable task) { if (task == null) throw new NullPointerException(); RunnableFuture ftask = newTaskFor(task); execute(ftask); return ftask; }
其中使用了newTaskFor 方法：
protectedRunnableFuture newTaskFor(Callable callable) { return new FutureTask (callable); }
newTaskFor 方法只是簡單的將給定可調(diào)用任務(wù)包裝成一個RunnableFuture ，使其具有取消運行的特性。而submit 中直接將任務(wù)交給execute() 運行.
再來看invokeAll() :
