详解JDK中ExecutorService与Callable和Future对线程的支持
成都创新互联长期为上1000+客户提供的网站建设服务，团队从业经验10年，关注不同地域、不同群体，并针对不同对象提供差异化的产品和服务；打造开放共赢平台，与合作伙伴共同营造健康的互联网生态环境。为彭泽企业提供专业的成都网站制作、成都网站设计，彭泽网站改版等技术服务。拥有十载丰富建站经验和众多成功案例,为您定制开发。
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{ 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{ 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方法时，如果线程还没有执行完，程序阻塞在这里，知道线程执行完。
重庆分公司
重庆分公司
package com.wang.test.concurrent;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class Client {
public static void main(String[] args) throws Exception {
ExecutorService pool = Executors.newFixedThreadPool(4);
Task1 t1 = new Task1(1,2);
Task1 t2 = new Task1(23,34);
Task1 t3 = new Task1(23,456);
Task1 t4 = new Task1(3,33);
Future f1 = pool.submit(t1);
Future f2 = pool.submit(t2);
Future f3 = pool.submit(t3);
Future f4 = pool.submit(t4);
//Future调用get方法时，如果线程还没有执行完，程序阻塞在这里
Task2 t5 = new Task2(f1.get(), f2.get(), f3.get(), f4.get());
Future f5 = pool.submit(t5);
System.out.println(f5.get());
pool.shutdown();
}
}
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！
