摘要：批量在模式的講解中，說到模式是一種支持異步計算并可以返回計算結果，并在返回結果前可以阻塞調用者的線程對象模型。批量模式是在對模式的擴展。
批量 FutureTask
在Future模式的講解中，說到future模式是一種支持異步計算并可以返回計算結果，并在返回結果前可以阻塞調用者的線程對象模型。
批量Future模式是在對Future模式的擴展。比如有，一批FutureTask，我要把這批task打包到一起，等待整個任務包執(zhí)行完后，在返回給調用者，或在規(guī)定時間內返回計算結果。
在Jdk中實現的方法是：
// 支持超時的批量任務模式
List> invokeAll(Collection> tasks,
long timeout, TimeUnit unit)
throws InterruptedException;
List> invokeAll(Collection> tasks)
throws InterruptedException;
JDK的一種簡單實現方式
Jdk在實現這種模式時，用了一個ArrayList存放task包，每個task還是多帶帶的送入到調度器中，然后在等待每個task的計算結果，等到所有的task計算完成后在返回包含每個task的計算結果集合，否則阻塞當前調用線程
下面是jdk的實現源碼：
public List> invokeAll(Collection> tasks)
throws InterruptedException {
if (tasks == null)
throw new NullPointerException();
// 存放task的集合
List> futures = new ArrayList>(tasks.size());
boolean done = false;
try {
// 每個task都送入到調度器
for (Callable t : tasks) {
RunnableFuture f = newTaskFor(t);
futures.add(f);
execute(f);
}
// 等待每一個task返回計算結果
for (Future f : futures) {
if (!f.isDone()) {
try {
f.get();
} catch (CancellationException ignore) {
// 如果其中有task被取消了，則忽略
} catch (ExecutionException ignore) {
}
}
}
done = true;
return futures;
} finally {
if (!done)
for (Future f : futures)
f.cancel(true);
}
}
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉載請注明本文地址：http://m.hztianpu.com/yun/64703.html
