jdk1.7.0_79

本文实际上是对上文《简单谈谈ThreadPoolExecutor线程池之submit方法》的一个延续或者一个补充。在上文中提到的submit方法里出现了FutureTask，这不得不停止脚步将方向转向Java的Future模式。

Future是并发编程中的一种设计模式，对于多线程来说，线程A需要等待线程B的结果，它没必要一直等待B，可以先拿到一个未来的Future，等B有了结果后再取真实的结果。

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(callable); //主线程需要callable线程的结果，先拿到一个未来的Future
System.out.println(future.get()); //有了结果后再根据get方法取真实的结果,当然如果此时callable线程如果没有执行完get方法会阻塞执行完，如果执行完则直接返回结果或抛出异常

也就是说，Future它代表一个异步计算的结果。

上面就代表了Future模式的执行原理，根据网上的例子，我们可以来自己实现一个Future模式。

package com.future;

/**
 * 数据结果
 * Created by yulinfeng on 6/18/17.
 */
public interface Data {
 String getResult() throws InterruptedException;
}

package com.future;

/**
 * 结果的真实计算过程
 * Created by yulinfeng on 6/18/17.
 */
public class RealData implements Data {
 protected String data;

 public RealData(String data) {
  try {
   System.out.println("正在计算结果");
   Thread.sleep(3000);  //模拟计算
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  this.data = data + “ world”;
 }

 public String getResult() throws InterruptedException {
  return data;
 }
}

package com.future;

/**
 * 真实结果RealData的代理
 * Created by yulinfeng on 6/18/17.
 */
public class FutureData implements Data {
 RealData realData = null; //对RealData的封装，代理了RealData
 boolean isReady = false; //真实结果是否已经准备好

 public synchronized void setResultData(RealData realData) {
  if (isReady) {
   return;
  }
  this.realData = realData;
  isReady = true;
  notifyAll(); //realData已经被注入到了futureData中，通知getResult方法
 }

 public synchronized String getResult() throws InterruptedException {
  if (!isReady) {
   wait();  //数据还未计算好，阻塞等待
  }
  return realData.getResult();
 }
}

package com.future;

/**
 * Client主要完成的功能包括：1. 返回一个FutureData；2.开启一个线程用于构造RealData
 * Created by yulinfeng on 6/18/17.
 */
public class Client {

 public Data request(final String string) {
  final FutureData futureData = new FutureData();

  /*计算过程比较慢，单独放到一个线程中去*/
  new Thread(new Runnable() {

   public void run() {
    RealData realData = new RealData(string);
    futureData.setResultData(realData);
   }
  }).start();

  return futureData; //先返回一个“假”的futureData
 }
}

/**
 * 负责调用Client发起请求，并使用返回的数据。
 * Created by yulinfeng on 6/18/17.
 */
public class Main {
 public static void main(String[] args) throws InterruptedException {
  Client client = new Client();
  System.out.println("准备计算结果");
  Data data = client.request("hello"); //立即返回一个“假”的futureData，可以不用阻塞的等待数据返回，转而执行其它任务
  System.out.println("执行其它任务");
  Thread.sleep(3000);  //模拟执行其它任务
  System.out.println("数据的计算结果为：" + data.getResult());
 }
}

仔细阅读以上程序对Future模式的实现不难发现，Future模式是异步请求和代理模式的结合。当然在JDK中已经为我们实现好了Future模式。

修改RealData类：

package com.future;

import java.util.concurrent.Callable;

/**
 * 结果的真实计算过程
 * Created by yulinfeng on 6/18/17.
 */
public class RealData2 implements Callable<String> {
 protected String data;

 public RealData2(String data) {
  this.data = data;
 }
 public String call() throws Exception {
  try {
   System.out.println("正在计算结果");
   Thread.sleep(2000);  //模拟计算结果
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  this.data = data + " world";
  return data;
 }
}

修改Main测试类：

package com.future;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/**
 * 负责调用Executor的submit，并使用返回的数据。
 * Created by yulinfeng on 6/18/17.
 */
public class Main2 {

 public static void main(String[] args) throws InterruptedException, ExecutionException {
  ExecutorService client = Executors.newSingleThreadExecutor(); //类似Client
  System.out.println("准备计算结果");
  Future<String> data = client.submit(new RealData2("hello")); //类似Client.request
  System.out.println("执行其它任务");
  Thread.sleep(3000);
  System.out.println("数据的计算结果为：" + data.get());
 }
}

现在回到上文还未解决完的AbstractExecutorService#submit方法。

类比上面的Client#request方法，在Client#request中先创建一个FutureData实例，而在AbstractExecutorService#submit中则是创建一个FutureTask实例，接着Client#request新创建一个线程用于异步执行任务，并直接返回FutureData，而在AbstractExecutorService#submit中同样也将任务交给了execute方法，并直接返回FutureTask。当然JDK中Future模式的实现更为复杂。

在《ThreadPoolExecutor线程池原理及其execute方法》中我们讲解了execute方法，在ThreadPoolExecutor$Worker#runWorker方法第1145行中是对task任务的调用：

//ThreadPoolExecutor$Worker#runWorker
task.run();

submit调用execute以执行run方法，实际执行的是FutureTask中的run方法。在FutureTask#run中，可以看到对任务Callable类型的task异步的执行，以及结果的保存。

以上这篇老生常谈java中的Future模式就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。

# java中的Future模式  # java Future 接口使用方法详解  # 简单讲解Java的Future编程模式  # Java利用future及时获取多线程运行结果  # Java多线程之异步Future机制的原理和实现  # 关于Java 中 Future 的 get 方法超时问题  # 浅谈在Java中使用Callable、Future进行并行编程  # java Callable与Future的详解及实例  # 浅谈Java多线程处理中Future的妙用（附源码）  # Java中Future接口详解  # 创建一个  # 而在  # 给大家  # 还未  # 的是  # 未来  # 好了  # 老生常谈  # 则是  # 我们可以  # 也将  # 给了  # 希望能  # 如果没有  # 可以看到  # 这篇  # 中去  # 在上  # 没必要  # 抛出 

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

相关推荐： Gemini怎么用新功能实时问答_Gemini实时问答使用【步骤】  如何在Ubuntu系统下快速搭建WordPress个人网站？  教你用AI润色文章，让你的文字表达更专业  ChatGPT怎么生成Excel公式_ChatGPT公式生成方法【指南】  VIVO手机上del键无效OnKeyListener不响应的原因及解决方法  如何彻底卸载建站之星软件？  Laravel如何实现数据导出到CSV文件_Laravel原生流式输出大数据量CSV【方案】  EditPlus 正则表达式 实战(3)  Laravel如何集成微信支付SDK_Laravel使用yansongda-pay实现扫码支付【实战】  高性能网站服务器配置指南：安全稳定与高效建站核心方案  如何快速辨别茅台真假？关键步骤解析  Laravel如何发送系统通知？（Notification渠道示例）  Laravel如何正确地在控制器和模型之间分配逻辑_Laravel代码职责分离与架构建议  历史网站制作软件,华为如何找回被删除的网站？  Zeus浏览器网页版官网入口 宙斯浏览器官网在线通道  如何在IIS服务器上快速部署高效网站？  Laravel用户认证怎么做_Laravel Breeze脚手架快速实现登录注册功能  Laravel怎么使用Blade模板引擎_Laravel模板继承与Component组件复用【手册】  Android自定义listview布局实现上拉加载下拉刷新功能  如何快速查询网址的建站时间与历史轨迹？  Python文件异常处理策略_健壮性说明【指导】  Laravel如何保护应用免受CSRF攻击？（原理和示例）  Laravel数据库迁移怎么用_Laravel Migration管理数据库结构的正确姿势  微信公众帐号开发教程之图文消息全攻略  手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站？  做企业网站制作流程,企业网站制作基本流程有哪些？  如何快速建站并高效导出源代码？  JavaScript Ajax实现异步通信  Laravel怎么使用Session存储数据_Laravel会话管理与自定义驱动配置【详解】  Swift开发中switch语句值绑定模式  javascript和jQuery中的AJAX技术详解【包含AJAX各种跨域技术】  网站建设保证美观性，需要考虑的几点问题！  Laravel Blade组件怎么用_Laravel可复用视图组件的创建与使用  HTML5段落标签p和br怎么选_文本排版常用标签对比【解答】  油猴 教程,油猴搜脚本为什么会网页无法显示？  如何快速查询网站的真实建站时间？  七夕网站制作视频,七夕大促活动怎么报名？  如何自定义建站之星模板颜色并下载新样式？  Java Adapter 适配器模式（类适配器，对象适配器）优缺点对比  Laravel API路由如何设计_Laravel构建RESTful API的路由最佳实践  详解jQuery中基本的动画方法  香港服务器建站指南：外贸独立站搭建与跨境电商配置流程  Android中AutoCompleteTextView自动提示  javascript如何操作浏览器历史记录_怎样实现无刷新导航  Laravel如何配置和使用缓存？（Redis代码示例）  Laravel如何设置自定义的日志文件名_Laravel根据日期或用户ID生成动态日志【技巧】  html5如何设置样式_HTML5样式设置方法与CSS应用技巧【教程】  电商网站制作多少钱一个,电子商务公司的网站制作费用计入什么科目？  如何安全更换建站之星模板并保留数据？  Win11怎么开启自动HDR画质_Windows11显示设置HDR选项