详解JDK中ExecutorService与Callable和Future对线程的支持

详解JDK中ExecutorService与Callable和Future对线程的支持

1、代码背景：

假如有Thread1、Thread2、Thread3、Thread4四条线程分别统计C、D、E、F四个盘的大小，所有线程都统计完毕交给Thread5线程去做汇总，应当如何实现？

2、代码：

统计“盘子”大小的代码，此处实现jdk中的Callable接口，

package com.wang.test.concurrent;

import java.util.concurrent.Callable;

public class Task1 implements Callable<Integer> {

private int x;

private int y;

public Task1(int x, int y) {

this.x = x;

this.y = y;

}

@Override

public Integer call() throws Exception {

return x*y;

}

统计汇总的代码，也是实现jdk中的Callable接口，

package com.wang.test.concurrent;

import java.util.concurrent.Callable;

public class Task2 implements Callable<Integer> {

private int x;

private int y;

private int q;

private int w;

public Task2(int x, int y, int q, int w) {

this.x = x;

this.y = y;

this.q = q;

this.w = w;

}

@Override

public Integer call() throws Exception {

return x + y + q + w;

}

客户端：使用JDK中Executors.newFixedThreadPool方法创建ExecutorService，ExecutorService的submit方法接收Callable接口的实现，JDK内部将弄成线程处理，使用Future接收submit方法的返回值，当future调用get方法时，如果线程还没有执行完，程序阻塞在这里，知道线程执行完。