详解JDK中ExecutorService与Callable和Future对线程的支持_网络技术

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

发布时间 - 2026-01-11 03:22:23 点击率：次

详解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方法时，如果线程还没有执行完，程序阻塞在这里，知道线程执行完。

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<Integer> f1 = pool.submit(t1); 
    Future<Integer> f2 = pool.submit(t2); 
    Future<Integer> f3 = pool.submit(t3); 
    Future<Integer> f4 = pool.submit(t4); 
     
    //Future调用get方法时，如果线程还没有执行完，程序阻塞在这里 
    Task2 t5 = new Task2(f1.get(), f2.get(), f3.get(), f4.get()); 
    Future<Integer> f5 = pool.submit(t5); 
     
    System.out.println(f5.get()); 
     
    pool.shutdown(); 
  } 
}

如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# JDK # ExecutorService # JDK中ExecutorService与Callable和Future对线程的支持 # ExecutorService实现获取线程返回值 # Java ScheduledExecutorService定时任务案例讲解 # java多线程CountDownLatch与线程池ThreadPoolExecutor/Execut # Java使用Callable和Future创建线程操作示例 # java通过Callable和Future来接收线程池的执行结果 # ExecutorService Callable Future多线程返回结果原理 # 在这里 # 还没有 # 如有 # 希望能 # 去做 # 谢谢大家 # 四条 # 如何实现 # 弄成 # 返回值 # 客户端 # 疑问请 # concurrent # import # test # wang # gt # Integer # int # private

相关栏目：【网站优化151355 】【网络推广146373 】【网络技术251811 】【 AI营销90571 】

上一篇：Win11怎么更改文件夹图标_自定义Win11文件夹外观样式

下一篇：详解JAVA调用WCF服务的示例代码

相关栏目网站优化
网络推广
网络技术
AI营销

最新文章 Sublime怎么一键压缩JS代码 Su sublime如何在搜索中使用正则表达式 Sublime如何设置透明窗口效果 Su mysql如何设计商品表结构_mysql css属性背景图不显示怎么办_通过检查路如何使用Golang实现排序_Golan 农历闰月是怎么回事_为合回归年加一月调整塑造《刺客信条》艾吉奥传奇的编剧离开育碧 1英里等于多少公里 1mile和km的换 css grid布局中行和列是如何定义的 PS批量旋转和翻转图片，快速校正图片方向 C# Swagger UI自定义方法 C OPPO手机九宫格和全键盘怎么切换_OP Go语言如何实现用户登录注册_Golan 1节飞行速度多少公里每小时 1节是多少公纸嫁衣8千子树第五章庙门怎么开启庙门 Laravel 多行数据编辑表单中实现逐明日之后如何提升钓鱼等级明日之后提升钓支付宝怎样查年度账单_支付宝年度账单查看 C# 多线程UI更新Dispatcher

上一篇：Win11怎么更改文件夹图标_自定义Win11文件夹外观样式

下一篇：详解JAVA调用WCF服务的示例代码