java Executors ExecutorService

ExecutorServiceTest.java

ExecutorService es = Executors.newCachedThreadPool();
ExecutorCompletionService<Boolean> ecs = new ExecutorCompletionService<>(es);
Set<Future> futureSet = new HashSet<Future>();

List<Callable> callerList = new ArrayList<Callable>();
// 构造任务列表
for (int i = 0; i < 100; i++) {
    callerList.add(...);   
}

// 提交任务，并添加到等待结果集合
for (Callable caller : callerList) {
    Future<Boolean> f = ecs.submit(caller);
    futureSet.add(f);
}

while (!futureSet.isEmpty()) {
    Future<Boolean> f = ecs.take();
    // 取得结果
    System.out.println(f.get());
    // 从等待结果集合中移除
    futureSet.remove(f);
}