Java线程立刻处理刚完成的任务实例源码介绍。ExecutorService的invokeAll()方法可以一次启动多个线程，并将这些线程的执行结果放入一个List。这是一个很方便的方法，但有不足之处，那就是必须等待所有线程全部结束之后，才会返回List，之后才能处理线程的结果。若有些线程执行很快，比如几秒就结束了，另一些线程执行很慢，要几小时，那么短时间线程的执行结果仍然无法立刻获取，必须等几小时之后，所有线程都结束了，他们的执行结果才可用。

改进方法是，利用Future对象的isDone()方法，通过循环随时检测是否有线程执行完毕，一旦发现结束的线程，就能够立刻处理他的结果。例子如下：

public class ThreadLocalTest {

public static void main(String[] args) throws Exception {
ExecutorService es = Executors.newFixedThreadPool(10);
List<Future<String>> list = new ArrayList<>();
Future<String> f = null;
//给每个任务分配一个线程
for(int i=0; i<5; i++) {
f = es.submit(new MyTask());
list.add(f);
}

//所有任务都开始执行后，关闭线程池
es.shutdown();

//通过循环找到刚刚结束的任务，然后立刻处理该任务的返回值
int n=5, i;
while(n>0) {
for(i=0; i<n; i++) {
f = list.get(i);
if(f.isDone()) {
System.out.println(f.get());
list.remove(i);
n–;
break;
}
}
}
System.out.println(“主线程结束”);
}
}

class MyTask implements Callable<String> {

@Override
public String call() throws Exception {
//随机休眠几秒钟，最后返回当前线程的名字
Random rand = new Random();
int n = rand.nextInt(10);
TimeUnit.SECONDS.sleep(n);
return Thread.currentThread().getName();
}

}