摘要：批量在模式的講解中，說到模式是一種支持異步計算并可以返回計算結(jié)果，并在返回結(jié)果前可以阻塞調(diào)用者的線程對象模型。批量模式是在對模式的擴展。
批量 FutureTask
在Future模式的講解中，說到future模式是一種支持異步計算并可以返回計算結(jié)果，并在返回結(jié)果前可以阻塞調(diào)用者的線程對象模型。
批量Future模式是在對Future模式的擴展。比如有，一批FutureTask，我要把這批task打包到一起，等待整個任務(wù)包執(zhí)行完后，在返回給調(diào)用者，或在規(guī)定時間內(nèi)返回計算結(jié)果。
在Jdk中實現(xiàn)的方法是：
// 支持超時的批量任務(wù)模式
List> invokeAll(Collection> tasks,
long timeout, TimeUnit unit)
throws InterruptedException;
List> invokeAll(Collection> tasks)
throws InterruptedException;
JDK的一種簡單實現(xiàn)方式
Jdk在實現(xiàn)這種模式時，用了一個ArrayList存放task包，每個task還是多帶帶的送入到調(diào)度器中，然后在等待每個task的計算結(jié)果，等到所有的task計算完成后在返回包含每個task的計算結(jié)果集合，否則阻塞當前調(diào)用線程
下面是jdk的實現(xiàn)源碼：
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都送入到調(diào)度器
for (Callable t : tasks) {
RunnableFuture f = newTaskFor(t);
futures.add(f);
execute(f);
}
// 等待每一個task返回計算結(jié)果
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);
}
}
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://www.ezyhdfw.cn/yun/64703.html
