Future、CompletionService、CompletableFuture介绍与对比

目录

  • Future
    • 1、基本介绍
    • 2、按照提交任务的顺序获取执行结果
  • CompletionService
    • 1、介绍
    • 2、按照任务完成的先后顺序获取结果
  • CompletableFuture
    • 1、介绍
    • 2、CompletableFuture怎么非阻塞的获取任务结果

Future

1、基本介绍

Future是JDK1.5 提供的接口,是用来以阻塞的方式获取线程异步执行完的结果。

FutureTask 类是 Java 中 Future 接口的一个实现,同时也实现了 Runnable 接口。它用于表示异步计算的结果,允许一个任务在一个线程中计算结果,在另一个线程中获取计算的结果。

import java.util.concurrent.*;public class CallableWithThreadPoolExample {public static void main(String[] args) {// 创建一个固定大小的线程池ExecutorService executorService = Executors.newFixedThreadPool(2);// 创建一个Callable任务Callable<Integer> callableTask = () -> {// 模拟耗时的计算try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}// 返回计算结果return 42;};// 提交Callable任务给线程池执行Future<Integer> future = executorService.submit(callableTask);// 执行其他任务,不会阻塞try {// 获取Callable任务的结果,会阻塞直到结果准备好Integer result = future.get();System.out.println("Result: " + result);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();} finally {// 关闭线程池executorService.shutdown();}}
}

2、按照提交任务的顺序获取执行结果

FutureTask 提供了 get 方法,可以用于获取异步计算的结果。然而,FutureTask 本身并没有保证按照任务提交的顺序返回结果。

如果你需要按照任务提交的顺序获取执行结果,你可以使用 ExecutorService 的 invokeAll 方法提交一批 Callable 任务,并得到一组 Future 对象,然后可以通过迭代这组 Future 对象来获取执行结果,迭代的顺序即为任务提交的顺序。

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;public class OrderPreservingExample {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(5);List<Callable<String>> tasks = new ArrayList<>();for (int i = 0; i < 10; i++) {final int taskId = i;Callable<String> task = () -> {// Simulate some computationThread.sleep(1000);return "Task " + taskId + " completed";};tasks.add(task);}try {List<Future<String>> results = executorService.invokeAll(tasks);for (Future<String> result : results) {System.out.println(result.get()); // Results are obtained in the order of task submission}} catch (InterruptedException | ExecutionException e) {e.printStackTrace();} finally {executorService.shutdown();}}
}

在上面的示例中,invokeAll 方法会按照任务列表的顺序返回 Future 对象的列表,因此通过迭代这个列表,可以按照任务提交的顺序获取执行结果。请注意,invokeAll 方法会阻塞直到所有任务完成。

CompletionService

1、介绍

CompletionService 是 Java 中用于处理一批异步任务的工具类,它允许你以异步的方式提交任务,并在任务完成时按照完成顺序获取结果。CompletionService 的底层原理主要基于阻塞队列和线程池。

CompletionService 使用一个阻塞队列来保存已完成的任务。当一个任务完成时,它会被放入队列中。阻塞队列的选择通常是 LinkedBlockingQueue,它是一个先进先出的队列,确保按照任务完成的顺序排列。

CompletionService 通常与 Executor 框架一起使用。创建一个 ExecutorService,并将其传递给 CompletionService 的构造函数。这个线程池负责执行提交的任务。

当想要获取已完成的任务的结果时,可以调用 CompletionService 的 take() 或 poll() 方法。这些方法会从阻塞队列中取出已完成的任务的 Future,并返回它。如果队列为空,take() 方法会阻塞,而 poll() 方法会返回 null。

由于使用了阻塞队列,你可以确保按照任务完成的顺序获取结果,即使任务的完成顺序与它们被提交的顺序不同。

2、按照任务完成的先后顺序获取结果

Future 接口本身并没有直接提供按照任务提交的顺序获取执行结果的机制。当通过 ExecutorService 提交多个任务时,Future 对象的完成顺序可能不一定与任务的提交顺序完全一致。

ExecutorCompletionService 是 ExecutorService 的一个实现,它可以将已完成的任务放入一个阻塞队列中,然后可以通过检索队列的元素来按照任务完成的顺序获取结果。

当向 CompletionService 提交一个任务时,它会将该任务包装在一个 Future 中,并将这个 Future 放入阻塞队列中。

import java.util.concurrent.*;public class OrderPreservingFutureExample {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(5);ExecutorCompletionService<String> completionService = new ExecutorCompletionService<>(executorService);for (int i = 0; i < 10; i++) {final int taskId = i;Callable<String> task = () -> {// Simulate some computationThread.sleep(1000);return "Task " + taskId + " completed";};completionService.submit(task);}try {for (int i = 0; i < 10; i++) {Future<String> result = completionService.take(); // Blocking until a task is completedSystem.out.println(result.get()); // Results are obtained in the order of completion}} catch (InterruptedException | ExecutionException e) {e.printStackTrace();} finally {executorService.shutdown();}}
}

在上面的示例中,ExecutorCompletionService 的 take 方法会阻塞直到有任务完成,然后返回一个 Future 对象,我们能够通过这个对象获取任务的执行结果。通过循环迭代 take 方法,可以按照任务完成的顺序获取执行结果。

这是因为CompletionService 的 take 方法是阻塞的。当调用 take 方法时,它会等待至少一个任务完成并返回一个包含已完成任务结果的 Future 对象。如果当前没有已完成的任务,take 方法会阻塞直到有任务完成为止。这种阻塞行为使得能够按照任务完成的顺序获取结果,因为它会返回最先完成的任务的结果。

如果我们希望非阻塞地检查是否有任务完成,可以使用 poll 方法,它会立即返回一个 Future 对象,如果没有已完成的任务,则返回 null。但使用 poll 方法可能需要在循环中进行主动轮询。

import java.util.concurrent.*;public class PollingCompletionServiceExample {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(5);CompletionService<String> completionService = new ExecutorCompletionService<>(executorService);// 提交任务到CompletionServicefor (int i = 0; i < 5; i++) {final int taskId = i;Callable<String> task = () -> {// 模拟一些计算Thread.sleep(1000);return "Task " + taskId + " completed";};completionService.submit(task);}// 轮询任务的完成状态for (int i = 0; i < 5; i++) {Future<String> result = completionService.poll();if (result != null) {// 任务已完成,处理结果try {System.out.println(result.get());} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}} else {// 没有已完成的任务System.out.println("No completed tasks at the moment.");}}executorService.shutdown();}
}

在上面的示例中,poll方法被用于轮询已完成的任务。如果有任务已经完成,它会返回一个包含任务结果的Future对象;否则,返回null。需要注意的是,如果任务尚未完成,poll方法会立即返回null,因此你可能需要在循环中添加适当的延迟,以避免过于频繁地检查任务状态。

CompletableFuture

1、介绍

Future和CompletionService 在实际使用过程中存在一些局限性比如不支持异步任务的编排组合、获取计算结果的 get() /take()为阻塞调用。

Java 8 才被引入CompletableFuture 类可以解决Future 的这些缺陷。CompletableFuture 除了提供了更为好用和强大的 Future 特性之外,还提供了函数式编程、异步任务编排组合(可以将多个异步任务串联起来,组成一个完整的链式调用)等能力。

CompletableFuture 同时实现了 Future 和 CompletionStage 接口。

CompletionStage 接口描述了一个异步计算的阶段。很多计算可以分成多个阶段或步骤,此时可以通过它将所有步骤组合起来,形成异步计算的流水线。

CompletableFuture 除了提供了更为好用和强大的 Future 特性之外,还提供了函数式编程的能力。

2、CompletableFuture怎么非阻塞的获取任务结果

通过 thenApply, thenAccept, 或者 thenRun 方法,注册回调函数,这些函数会在 CompletableFuture 完成时被异步调用。这样,处理任务的结果而不必阻塞当前线程。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");future.thenApply(result -> {// Non-blocking callback to process the resultSystem.out.println("Received result: " + result);return result.toUpperCase();
});// Continue with other non-blocking operations

使用 thenCombine, thenAcceptBoth, runAfterBoth, applyToEither, acceptEither, 等方法,将多个 CompletableFuture 的结果组合在一起,而不必阻塞等待每个任务的完成。


CompletableFuture<String> firstTask = CompletableFuture.supplyAsync(() -> {// Simulate some computationreturn "First Task";
});CompletableFuture<String> secondTask = CompletableFuture.supplyAsync(() -> {// Simulate some computationreturn "Second Task";
});CompletableFuture<String> thirdTask = CompletableFuture.supplyAsync(() -> {// Simulate some computationreturn "Third Task";
});// 使用thenCompose确保任务按照顺序完成
CompletableFuture<String> result = firstTask.thenCompose(result1 ->secondTask.thenCompose(result2 ->thirdTask.thenApply(result3 -> result1 + " -> " + result2 + " -> " + result3))
);// 异步获取结果
result.thenAcceptAsync(System.out::println);// 阻塞等待所有任务完成
result.join();

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/599045.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python每日一题:连续子数组的最大和

这是一道关于动态规划的算法题&#xff1a; 题目描述&#xff1a; 给定一个整数数组 nums&#xff0c;请找出该数组中连续子数组的最大和&#xff0c;并返回这个最大和。 示例&#xff1a; 输入&#xff1a;[-2, 1, -3, 4, -1, 2, 1, -5, 4] 输出&#xff1a;6 解释&#xff…

如何用Rust编程访问未知结构的json串?

如何用Rust访问未知结构的JSON串&#xff0c;并包含对数组的访问&#xff1f;以下是一个简单的示例&#xff1a; use serde_json::{Value};fn main() {let json_str r#"{"name":"John","age":30,"city":"New York",&q…

数据库基础知识1

关系模型的程序员不需熟悉数据库的存取路径 在3层模式结构中,___I___是数据库的核心和关键,___Ⅱ___通常是模式的子集,数据库模式的描述提供给用户,____Ⅲ__的描述存储在硬盘上。Ⅰ.模式Ⅱ. 外模式Ⅲ. 内模式 数据库中,数据的物理独立性是指用户的应用程序与存储在磁盘上数据库…

PHP篇——html+php实现表单提交的一个简单例子

html&#xff1a; <!DOCTYPE html> <html lang"zh"> <head><meta charset"UTF-8"><title>表单示例</title> </head> <body><!-- 创建表单 --><form action"form.php" method"po…

Rust:如何判断位置结构的JSON串的成员的数据类型

如何判断位置结构的JSON串的成员的数据类型&#xff0c;给一个Rust的例子&#xff0c;其中包含对数组的判断&#xff1f; 在Rust中&#xff0c;你可以使用serde_json库来处理JSON数据&#xff0c;并通过serde_json::Value类型的方法来判断JSON串中成员的数据类型。以下是一个示…

D6208双向直流马达驱动芯片 用于IPC产品,可兼容BA6208,噪声低 ,工作电源电压范围宽。

D6208 是一块单片双向马达驱动电路&#xff0c;它使用TTL电平的逻辑信号就能控制卡式录音机和其它电子设备中的双向马达。该电路由一个逻辑部分和一个功率输出部分组成。逻辑部分控制马达正、反转向及制动&#xff0c;功率输出部分根据逻辑控制能提供100mA&#xff08;典型值&a…

迅腾文化观察:从“占位”到“心智”,从“借势”到“锁定”—— 高增长市场的企业战略之道

迅腾文化观察&#xff1a;从“占位”到“心智”&#xff0c;从“借势”到“锁定”—— 高增长市场的企业战略之道 在当今世界&#xff0c;市场环境瞬息万变&#xff0c;企业若想在激烈的市场竞争中立足并持续发展&#xff0c;必须不断地调整和优化自身的战略。在迅腾文化观察中…

electron进程通信之预加载脚本和渲染进程对主进程通信

主进程和预加载脚本通信 主进程 mian,js 和预加载脚本preload.js,在主进程中创建预加载脚本, const createWindow () > {// Create the browser window.const mainWindow new BrowserWindow({width: 300,height: 300,// 指定预加载脚本webPreferences: {preload: path.j…

web3 : blockscout剖析

Blockscout 是第一个功能齐全的开源区块链浏览器,可供任何以太坊虚拟机 (EVM) 链使用。项目方可以下载并使用Blockscout作为其链的浏览器,用户可以轻松验证交易、余额、区块确认、智能合约和其他记录。 目录 Blockscout可以做什么主要特征blockscoutDocker容器组件Postgres 1…

二刷Laravel 教程(优化页面)总结Ⅱ

一、样式美化 Bootstrap 1&#xff09;Laravel 项目中使用 Bootstrap 前端框架&#xff0c;需要先执行以下命令&#xff1a; composer require laravel/ui:3.4.5 --dev composer require 是用来安装扩展包使用的命令。 参数 --dev 是指定此扩展包只在开发环境中使用。 2&am…

队列的数据结构实验报告

实验目的&#xff1a; 1、理解队列数据结构的概念和特点。 2、熟悉队列的应用场景和算法实现。 二、实验内容&#xff08;实验题目与说明&#xff09; 实现了一个循环队列&#xff0c;具有功能&#xff1a; 初始化队列。判断队列是否为空。判断队列是否已满。入队。出队。…

CSS基本知识

文章目录 1. CSS 是什么2. 基本语法规范3. 引入方式3.1 内部样式表3.2 行内样式表3.3 外部样式 4. 选择器4.1 选择器的功能4.2 选择器的种类4.3 基础选择器4.3.1 标签选择器4.3.2 类选择器4.3.3 id 选择器4.3.4 通配符选择器 4.4 复合选择器4.4.1 后代选择器4.4.2 伪类选择器 5…

【fiddler】fiddler抓包工具的使用

前言&#xff1a;我们可以通过fiddler软件&#xff0c;捕获到http请求&#xff0c;并修改请求参数 修改返回内容 fiddler下载,官网如下图 启动fiddler软件,点击file 选择 Capture Traffic 修改入参 (我们以谷歌浏览器发起请求为例) 此时会出现一个向上的箭头&#xff0c;点击…

Linux第8步_USB设置

学习完设置“虚拟机的电源”后&#xff0c;接着学习通过鼠标点击操作U盘&#xff0c;目的是了解USB设置。 1、在桌面&#xff0c;双击“VMware Workstation Pro”图标&#xff0c;得到下图&#xff1a; 2、点击“编辑虚拟机”&#xff0c;得到下图&#xff1a; 只要点击编辑虚…

Rockchip平台双屏异显功能实现(基于Android13)

Rockchip平台双屏异显功能实现(基于Android13) 1. 异显实现方案 Rockchip SDK平台支持两种不同的异显方案&#xff1a;Android Presentation和Android Activity指定屏幕启动。 使用Android Presentation方案&#xff0c;需要在APP开发中调用相应接口以使指定视图&#xff08…

【软件测试】2024年准备中/高级测试岗技术面试...

目录&#xff1a;导读 前言一、Python编程入门到精通二、接口自动化项目实战三、Web自动化项目实战四、App自动化项目实战五、一线大厂简历六、测试开发DevOps体系七、常用自动化测试工具八、JMeter性能测试九、总结&#xff08;尾部小惊喜&#xff09; 前言 1、软件测试基础知…

建设数字工厂管理系统解决方案需要哪些技术

随着科技的快速发展&#xff0c;数字化转型已成为工厂提升生产效率、降低成本、增强竞争力的关键。数字工厂管理系统作为这一转型的核心&#xff0c;集成了各种先进的技术&#xff0c;以确保工厂运行的流畅和高效。本文将深入探讨建设数字工厂管理系统解决方案所需的关键技术。…

python深度拷贝

在Python中&#xff0c;可以使用copy.deepcopy()函数来进行深度拷贝。 深度拷贝会递归地将所有子对象都复制到一个新的对象中。这意味着即使原始对象包含其他对象&#xff0c;也会将它们完全拷贝到新的对象中。 下面是一个使用copy.deepcopy()函数进行深度拷贝的示例&#xf…

DS|树结构及应用

题目一&#xff1a;DS树 -- 树的先根遍历&#xff08;双亲转先序&#xff09; 题目描述&#xff1a; 给出一棵树的双亲表示法结果&#xff0c;用一个二维数组表示&#xff0c;位置下标从0开始&#xff0c;如果双亲位置为-1则表示该结点为根结点 编写程序&#xff0c;输出该树…

17、Kubernetes核心技术 - 污点(Taints)和污点容忍(Tolerations)

目录 一、概述 二、污点和污点容忍示例 2.1、NoSchedule 2.2、NoExecute 三、污点和污点容忍应用场景 四、k8s内置的一些污点 一、概述 上一篇文章介绍了节点亲和性&#xff0c;它主要实现的是将Pod强制或者尽可能调度到满足某些条件的node节点上【通过在Pod上添加属性&…