CompleteFuture与Future的比较

    • CompleteFuture的介绍
    • CompleteFuture的特点
    • CompleteFuture的应用场景
    • CompletableFuture的优缺点
    • Future的介绍
    • Future的特点
    • Future的应用场景
    • Future的优缺点
    • CompletableFuture和Future的区别
    • CompletableFuture和Future的关联关系
    • CompletableFuture和Future的使用示例
      • CompletableFuture使用示例
      • Future使用示例
    • CompletableFuture应用步骤

在这里插入图片描述

CompleteFuture的介绍

CompletableFuture是Java 8提供的一种基于Future的异步编程的实现。它不仅可以代表异步计算的结果,还能够定义它完成之后的回调函数。它的实现在java.util.concurrent.CompletableFuture的包内。

CompletableFuture的实现涉及到JDK 8的几个新特性,如Lambda、Stream、线程池等,它允许把任务池、线程池和阻塞队列组合在一起,使得开发者可以更加简单地实现异步编程,对程序的执行性能也带来了一定的提升。

与Future相比,CompletableFuture的优势在于:

  1. 可以直接对多个任务进行链式、组合等处理,而不需要借助并发工具类。
  2. 实现了对任务编排的能力,可以轻松地组织不同任务的运行顺序、规则以及方式。

CompleteFuture的特点

CompletableFuture的特点主要包括异步执行、链式操作和灵活性强

  1. 异步执行:CompletableFuture允许任务在后台线程中异步执行,不会阻塞主线程,提高了应用程序的响应性和性能。
  2. 链式操作:CompletableFuture支持链式操作,可以方便地处理任务的依赖关系和结果转换。
  3. 灵活性强:相比于传统的Future接口,CompletableFuture更加灵活和强大,提供了丰富的方法来处理异步操作和多个任务的结果。

CompleteFuture的应用场景

CompletableFuture的应用场景主要包括异步编程、任务组合和并发编程

  1. 异步编程:在需要执行耗时操作的情况下,使用CompletableFuture可以实现异步执行,避免阻塞主线程,提高程序的响应性和性能。
  2. 任务组合:CompletableFuture支持链式操作,可以将多个异步任务组合在一起,按照指定的顺序和逻辑执行,实现任务的依赖关系和结果转换。
  3. 并发编程:在多线程环境下,CompletableFuture可以方便地处理多个任务的结果,避免线程间的竞争和同步问题,提高并发编程的效率和可靠性。

CompletableFuture的优缺点

CompletableFuture的优点主要包括简洁易用、支持异步编程、任务组合和并发编程等。它提供了一种简洁的方式来处理异步计算和任务组合,使得异步编程更加容易和高效。

然而,CompletableFuture也存在一些缺点,例如:

  1. 无法对多个任务进行链式调用:如果希望在计算任务完成后执行特定动作,比如发邮件,但CompletableFuture却没有提供这样的能力。
  2. 无法组合多个任务:如果运行了10个任务,并期望在它们全部执行结束后执行特定动作,那么在CompletableFuture中这是无能为力的。
  3. 没有异常处理:CompletableFuture接口中没有关于异常处理的方法。

在这里插入图片描述

Future的介绍

Future是Java中用于异步计算的一个接口。它提供了一种方式,允许将一个耗时的计算任务放到另一个线程中执行,而主线程可以继续处理其他任务。

在Future接口中,通常包含一些方法,如isDone()、get()、cancel()等。isDone()方法用于检查Future是否已经完成,get()方法用于获取Future的结果,cancel()方法用于取消Future的计算任务。

使用Future接口可以实现异步计算,提高程序的执行效率。当需要执行一个耗时的计算任务时,可以创建一个Future对象,然后将该对象传递给异步线程执行。异步线程执行完成后,可以通过Future对象获取计算结果。


Future的特点

Future的特点主要有以下几个方面:

  1. 表示异步操作未完成时的状态:Future对象可以表示一个异步操作是否完成,如果异步操作未完成,Future对象的状态为未完成,如果异步操作完成,Future对象的状态为已完成。
  2. 可以用来获取异步操作完成后返回的结果:通过Future对象提供的get方法,可以获取异步操作完成后返回的结果。
  3. 不提供直接的方式来添加回调函数:Future不提供一种直接的方式来添加回调函数,处理操作完成后的结果或异常。
  4. 只能表示异步任务是否完成,而不能手动触发任务的完成或组合多个任务:Future只能表示异步任务是否完成,而不能手动触发任务的完成或组合多个任务。

Future的应用场景

Future的应用场景主要在并发编程中,当我们需要用到非阻塞的模型时,Future就显得尤为重要。

在Java多线程的三种实现中,无论是继承Thread类还是实现Runnable接口,都是异步的,并且主调函数无法获取到返回值。而Future则可以接收多线程的执行结果。具体来说,Future接收一个可能还没有完成的异步任务的结果,针对这个结果可以添加Callable以便任务执行成功或失败后作出相应的操作。

采用Future修改的异步方法,在每次被异步调用以后会马上返回(无论异步方法体是否执行完成),Future就会监听异步任务执行状态(成功、失败),等到执行完成以后,就能通过Future.get()方法获取到异步返回的结果。也就是说,如果批量调用采用Future修饰的异步方法,程序不会阻塞等待,然后再遍历Future列表,即可获取到所有的异步结果(Future的内部机制是等所有的异步任务完成了才进行遍历)。这种请求耗时只会略大于耗时最长的一个Future修饰的方法。


Future的优缺点

Future的优点主要包括:

  1. 异步处理:Future允许将耗时的计算任务放到另一个线程中执行,不会阻塞主线程,提高了程序的执行效率。
  2. 链式操作:Future支持链式操作,可以方便地处理任务的依赖关系和结果转换。

然而,Future也存在一些缺点:

  1. 阻塞获取结果:当需要获取Future的结果时,如果计算还没有完成,会导致程序阻塞。这可能会影响程序的性能和响应性。
  2. 无法添加回调函数:Future不提供一种直接的方式来添加回调函数,处理操作完成后的结果或异常。这使得在异步操作完成后,无法直接进行特定的处理。

在这里插入图片描述

CompletableFuture和Future的区别

CompletableFuture和Future的区别主要体现在以下几个方面:

  1. 功能区别 :Future只能用于获取异步计算的结果,而CompletableFuture除了能获取异步计算的结果外,还可以用于组合多个异步任务,处理异常情况,以及在任务完成时执行回调函数等。
  2. 阻塞区别 :Future的get方法是阻塞的,如果异步计算没有完成,它会一直等待直到计算完成。而CompletableFuture的get方法也是阻塞的,但是它可以设置超时时间,如果在指定的时间内计算没有完成,它会抛出TimeoutException异常。
  3. 异常处理区别 :Future的异常处理比较麻烦,需要在任务执行时捕获异常,然后将异常封装到Future对象中返回。而CompletableFuture的异常处理比较简单,可以使用exceptionally方法或handle方法来处理异常情况。
  4. 组合任务区别 :Future不支持组合多个异步任务,需要使用ExecutorService的submit方法来提交多个任务,并使用Future对象来获取每个任务的结果。而CompletableFuture支持组合多个异步任务,可以使用thenCompose、thenCombine、thenAcceptBoth等方法来组合多个任务。

CompletableFuture和Future的关联关系

CompletableFuture和Future之间存在关联关系,因为CompletableFuture实现了Future接口。这意味着CompletableFuture可以作为Future使用,同时它还提供了更多功能,如链式操作、异常处理和组合任务等。

CompletableFuture在内部使用了一个子线程来执行任务,并且提供了异步计算的结果。当异步计算完成时,CompletableFuture会自动将结果设置为已完成状态,并且可以通过get方法获取结果。

与Future相比,CompletableFuture提供了更多的功能和灵活性。它支持链式操作,可以将多个异步任务组合在一起,并且可以在任务完成后执行特定的回调函数。此外,CompletableFuture还提供了异常处理机制,可以捕获和处理任务执行过程中抛出的异常。

因此,CompletableFuture是Future的扩展和增强,它提供了更多的功能和灵活性,适用于需要处理异步计算和组合多个任务的场景。


CompletableFuture和Future的使用示例

CompletableFuture使用示例

以下是一个使用CompletableFuture的示例:

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            // 模拟耗时操作
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Hello, World!";
        });

        // 获取异步计算的结果
        String result = future.get();
        System.out.println(result);
    }
}

在这个示例中,我们使用CompletableFuture的supplyAsync方法创建了一个异步任务,该任务会返回一个字符串"Hello, World!"。然后,我们使用get方法获取异步计算的结果,并将其打印出来。这个示例演示了如何使用CompletableFuture来执行异步计算并获取结果。

Future使用示例

以下是一个使用Java Future的示例:

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

public class FutureExample {
    public static void main(String[] args) throws Exception {
        ExecutorService executor = Executors.newSingleThreadExecutor();

        // 提交任务并获取Future对象
        Future<String> future = executor.submit(() -> {
            // 模拟耗时操作
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Hello, World!";
        });

        // 获取异步计算的结果
        String result = future.get();
        System.out.println(result);

        // 关闭ExecutorService
        executor.shutdown();
    }
}

在这个示例中,我们使用ExecutorService的submit方法提交了一个异步任务,该任务会返回一个字符串"Hello, World!"。然后,我们使用Future的get方法获取异步计算的结果,并将其打印出来。最后,我们关闭了ExecutorService以释放资源。这个示例演示了如何使用Java Future来执行异步计算并获取结果。

在这里插入图片描述

CompletableFuture应用步骤

在项目中使用CompletableFuture,可以按照以下步骤进行:

  1. 导入CompletableFuture类:首先,需要在项目中导入CompletableFuture类,以便使用其功能。
  2. 创建异步任务:使用CompletableFuture的静态方法supplyAsync或runAsync来创建异步任务。supplyAsync方法接受一个Supplier接口的实现类作为参数,用于定义异步任务的逻辑。runAsync方法接受一个Runnable接口的实现类作为参数,用于定义异步任务的逻辑。
  3. 链式操作:使用CompletableFuture的thenApply、thenAccept、thenRun等方法来链式操作异步任务。这些方法接受一个Function、Consumer或Runnable接口的实现类作为参数,用于定义链式操作的逻辑。
  4. 异常处理:使用CompletableFuture的exceptionally方法来处理异步任务中抛出的异常。exceptionally方法接受一个Function接口的实现类作为参数,用于定义异常处理的逻辑。
  5. 获取结果:使用CompletableFuture的get方法来获取异步计算的结果。get方法会阻塞当前线程,直到异步计算完成并返回结果。

以下是一个简单的示例代码,演示了如何在项目中使用CompletableFuture:

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            // 模拟耗时操作
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Hello, World!";
        }).thenApply(result -> {
            // 链式操作:对结果进行处理
            return result.toUpperCase();
        }).thenAccept(result -> {
            // 链式操作:对结果进行处理并输出到控制台
            System.out.println(result);
        });

        // 获取异步计算的结果(如果需要)
        future.get();
    }
}

在上面的示例中,我们首先使用CompletableFuture的supplyAsync方法创建了一个异步任务,该任务会返回一个字符串"Hello, World!"。然后,我们使用thenApply方法对结果进行链式操作,将结果转换为大写字母。接着,我们使用thenAccept方法对结果进行链式操作,将结果输出到控制台。最后,我们使用get方法获取异步计算的结果(如果需要)。

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

基于点云去滤除灰尘的滤波算法调研

背景 激光雷达在恶劣天气下会影响感知识别的精度,造成误差,将灰尘,雨雪误识别为障碍物,为了降低对灰尘的误检,因此调研相关的灰尘滤波算法。 方法1 反射强度滤波+半径异常值移除 Design of a LIOR-Based De-Dust Filter for LiDAR Sensors inOff-Road Vehicles 1 上文中…

卷积神经网络的学习与实现

基于matlab的卷积神经网络(CNN)讲解及代码_matlab中如何查看cnn损失函数-CSDN博客 可以看到与BP神经网络相比&#xff0c;卷积神经网络更加的复杂&#xff0c;这里将会以cnn作为学习案例。 1.经典反向传播算法公式详细推导 这里引用经典反向传播算法公式详细推导_反向目标公…

关联规则 FP-Growth算法

FP-Growth算法 FP-growth 算法思想 FP-growth算法是韩家炜老师在2000年提出的关联分析算法&#xff0c;它采取如下分治策略: 将提供频繁项集的数据库压缩到一棵频繁模式树 (FP-Tree)但仍保留项集关联信息。FP-growth算法是对Apriori方法的改进。生成一个频繁模式而不需要生成…

SQLSERVER数据库主要状态和切换路径

前言 一个SQLSERVER数据库会处于很多种状态&#xff0c;例如 ONLINE 、RESTORING 、RECOVERING 、RECOVERY_PENDING 、SUSPECT、EMERGENCY 、OFFLINE等等。 只有在ONLINE的状态下&#xff0c;数据库才能被正常访问。 下图主要反映了数据库的主要状态之间的切换路径 下面说一…

【MAC】M2 安装mysql

一、docker下载地址 下载地址 二、安装docker完成 三、安装mysql 一、拉取镜像 # 拉取镜像 docker pull mysql# 或者 docker pull mysql:latest# 以上两个命令是一致的&#xff0c;默认拉取的就是 latest 版本的# 我们还可以用下面的命令来查看可用版本&#xff1a; docker…

数据结构(Chapter Two -02)—顺序表基本操作实现

在前一部分我们了解线性表和顺序表概念&#xff0c;如果有不清楚可以参考下面的博客&#xff1a; 数据结构(Chapter Two -01)—线性表及顺序表-CSDN博客 首先列出线性表的数据结构&#xff1a; #define MaxSize 50 //定义顺序表最大长度 typedef struct{ElemType data…

HarmonyOS4.0从零开始的开发教程19HarmonyOS应用/元服务上架

HarmonyOS&#xff08;十七&#xff09;HarmonyOS应用/元服务上架 概述 当您开发、调试完HarmonyOS应用/元服务&#xff0c;就可以前往AppGallery Connect申请上架&#xff0c;华为审核通过后&#xff0c;用户即可在华为应用市场获取您的HarmonyOS应用/元服务。 HarmonyOS会…

xxl-job 分布式调度学习笔记

1.概述 1.1什么是任务调度 业务场景&#xff1a; 上午10点&#xff0c;下午2点发放一批优惠券 银行系统需要在信用卡到期还款日的前三天进行短信提醒 财务系统需要在每天凌晨0:10分结算前一天的财务数据&#xff0c;统计汇总 不同系统间的数据需要保持一致&#xff0c;这时…

3.2 内容管理模块 - 课程分类、新增课程、修改课程

内容管理模块-课程分类、新增课程、修改课程 文章目录 内容管理模块-课程分类、新增课程、修改课程一、课程分类1.1 课程分类表1.2 查询树形结构1.2.1 表自连接1.2.2 SQL递归 1.3 Mapper1.4 Service1.5 Controller1.6 效果图 二、添加课程2.1 需求分析2.2 数据表2.2.1 课程基础…

html之CSS的高级选择器应用

文章目录 一、CSS高级选择器有哪些呢&#xff1f;二、高级选择器的应用1、层次选择器后代选择器子选择器相邻兄弟选择器通用兄弟选择器 2、结构伪类选择器&#xff08;不常用&#xff09;3、属性选择器E[attr]E[attrval]E[attr^val]E[attr$val]E[attr*val] 一、CSS高级选择器有…

LeetCode 每日一题 Day 13 || BFS

2415. 反转二叉树的奇数层 给你一棵 完美 二叉树的根节点 root &#xff0c;请你反转这棵树中每个 奇数 层的节点值。 例如&#xff0c;假设第 3 层的节点值是 [2,1,3,4,7,11,29,18] &#xff0c;那么反转后它应该变成 [18,29,11,7,4,3,1,2] 。 反转后&#xff0c;返回树的根…

NLP论文阅读记录-ACL 2023 | 10 Best-k Search Algorithm for Neural Text Generation

文章目录 前言0、论文摘要一、Introduction1.1目标问题1.2相关的尝试1.3本文贡献 二.相关工作2.1优势2.2 挑战 三.本文方法3.1 并行探索3.2 时间衰变3.3堆修剪3.4 模型得分 四 实验效果4.1数据集4.2 对比模型4.3实施细节4.4评估指标4.5 实验结果 五 总结 前言 用于神经文本生成…

安全生产隐患排查治理信息化系统软件

安全隐患排查系统实现对重大危险源企业、安全隐患信息的登记、整改、复查、分类和统计。系统涵盖了安全隐患排查整治工作的各项基本内容&#xff0c;实现以安全隐患排查整治业务流为主线&#xff0c;处理流程简洁清晰、快速灵活&#xff1b;以排查整治流程为干线&#xff0c;快…

Linux--学习记录(3)

G重要编译参数 -g&#xff08;GDB调试&#xff09; -g选项告诉gcc产生能被GNU调试器GDB使用的调试信息&#xff0c;以调试程序编译带调试信息的可执行文件g -g hello.c -o hello编译过程&#xff1a; -E&#xff08;预处理&#xff09; g -E hello.c -o hello.i-S&#xff08;编…

基于springboot+vue 的智能物流管理系统

简介 基于springbootvue 的智能物流管理系统 适用于 设计&#xff0c;课程设计参考与学习用途。仅供学习参考。 不得用于商业或者非法用途&#xff0c;否则&#xff0c;一切后果请用户自负。 看运行截图看 第五章 第四章 获取资料 **项目编号&#xff1a;springboot074 ** **…

算法专题二:滑动窗口

算法专题二&#xff1a;滑动窗口 一.长度最小的子数组&#xff1a;1.思路一&#xff1a;暴力解法2.思路二&#xff1a;滑动窗口双指针3.GIF题目解析&#xff1a;思路一&#xff1a;思路二&#xff1a; 二.无重复字符的最长子串&#xff1a;1.思路一&#xff1a;滑动窗口2.GIF题…

制作一个多行时正确宽度的Textview,Android Textview 换行时宽度过长 右侧空白区域挤掉页面元素的解决方案

优化 Android 布局&#xff1a;创建自适应宽度的 TextView 引言 在Android应用开发中&#xff0c;布局优化是提升应用性能和用户体验的关键环节之一。特别是对于那些内容密集型的应用&#xff0c;如何高效地展示和管理文本内容成为了一个挑战。最近&#xff0c;在处理一个布局…

【数据结构】模式匹配之KMP算法与Bug日志—C/C++实现

​&#x1f308;个人主页&#xff1a;Sarapines Programmer&#x1f525; 系列专栏&#xff1a;《数据结构奇遇记》&#x1f516;墨香寄清辞&#xff1a;墨痕寄壮志&#xff0c;星辰梦未满。 通幽径心凝意&#xff0c;剑指苍穹势如山。 目录 &#x1f31e;1. 模式匹配的基本概念…

Scala多线程爬虫程序的数据可视化与分析实践

一、Scala简介 Scala是一种多种类型的编程语言&#xff0c;结合了针对对象编程和函数式编程的功能。它运行在Java虚拟机上&#xff0c;具有强大的运算能力和丰富的库支持。Scala常用于大数据处理、并发编程和Web应用程序开发。其灵活性和高效性编程成为编写多线程爬虫程序的理…

科技云报道:至简至强,新一代服务器的算力美学

科技云报道原创。 在这个时代&#xff0c;数据和计算的边界正在迅速扩张。 随着云计算、物联网和人工智能的日益成熟&#xff0c;对算力的需求已经突破了传统的限制&#xff0c;进入了一个全新的阶段。在这个阶段&#xff0c;不仅是算力的量级发生了变化&#xff0c;其性质和…