java 如何快速实现异步调用方法

这篇具有很好参考价值的文章主要介绍了java 如何快速实现异步调用方法。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

什么是异步编程

在实现异步调用之前,我们先了解一下,什么是异步编程?什么场景下适用等等情况。

我们都知道,在传统的同步编程中,当一个操作开始执行时,程序会阻塞并等待该操作完成,然后才能继续执行后续代码。这种阻塞等待的方式可能会导致程序响应性能下降,因为在等待的过程中无法同时处理其他任务。这种显而易见的,在某种耗时的场景下,就显得无用了,甚至很影响体验。

如文件读写、网络请求或计算密集型任务,再如人脸融合特效等等,都是耗时的操作,这个时候,我们就需要异步编程了。

异步编程则不会阻塞程序的执行,它将耗时的操作提交给后台线程或其他执行环境,并立即返回,使得程序可以继续执行其他任务。当耗时操作完成后,会通过回调、事件或者轮询等方式通知主线程,主线程再去处理操作结果或执行相应的回调函数。

CompletableFuture

今天我们就来了解下 CompletableFuture,它Java 8引入的一种功能强大的异步编程工具,可以用于实现复杂的异步操作和处理链式的异步任务。

java方法异步执行,Java,# 多线程,java,微服务,多线程,异步编程,云原生,原力计划

从这个JDK里,可以看出,它既实现了 Future 接口,拥有 Future 所有的特性,比如可以使用 get() 方法获取返回值等。

也实现了CompletionStage接口,提供了丰富的方法来管理异步任务的执行和处理任务结果。并且这些接口多达40多个,完全足够我们日常所使用了。

1. supplyAsync

 1. CompletableFuture<T> supplyAsync(Supplier<? extends T> supplier)

该方法接受一个Supplier函数式接口作为参数,用于执行一个有返回值的异步任务。返回一个CompletableFuture对象,可以用于获取异步任务的执行结果。

参数:

Supplier:一个无参的函数式接口,用于提供异步任务的结果。

2. runAsync

2CompletableFuture<Void> runAsync(Runnable runnable)

该方法接受一个Runnable函数式接口作为参数,用于执行一个无返回值的异步任务。返回一个CompletableFuture对象,可以用于等待异步任务完成。

参数:
Runnable:一个无参的函数式接口,用于执行异步任务。

3. thenApply

3CompletableFuture<T> thenApply(Function<? super T,? extends U> function)

该方法接受一个Function函数式接口作为参数,用于对CompletableFuture的结果进行处理,并返回新的CompletableFuture对象。

参数:
Function:一个带有一个参数的函数式接口,用于对异步任务的结果进行转换或处理。

4. thenAccept

4CompletableFuture<Void> thenAccept(Consumer<? super T> consumer)

该方法接受一个Consumer函数式接口作为参数,用于对CompletableFuture的结果进行消费,没有返回值

参数:

Consumer:一个带有一个参数的函数式接口,用于消费异步任务的结果。

5. thenRun

5CompletableFuture<Void> thenRun(Runnable action)

该方法接受一个Runnable函数式接口作为参数,用于在CompletableFuture的结果完成后执行指定的操作,没有返回值。

参数:
BiFunction:一个带有两个参数的函数式接口,用于合并两个CompletableFuture的结果。

6. thenCombine

6CompletableFuture<U> thenCombine(CompletionStage<? extends V> other, BiFunction<? super T,? super U,? extends V> fn)

该方法接受一个CompletionStage对象和一个BiFunction函数式接口作为参数,用于等待当前CompletableFuture和另一个CompletionStage对象都完成后,将其结果进行组合处理,并返回新的CompletableFuture对象。

参数:

CompletionStage:代表一个异步任务的执行状态。

返回值:文章来源地址https://www.toymoban.com/news/detail-610519.html

  • CompletableFuture<T>:表示一个异步任务的结果,可以通过该对象获取异步任务的执行结果。
  • CompletableFuture<Void>:表示一个异步任务的结果,没有返回值。

java 演示

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

public class CompletableFutureExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 使用supplyAsync方法创建一个CompletableFuture对象来执行有返回值的异步任务
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
            System.out.println("异步任务正在执行");
            return 100;
        });
        
        // 使用thenApply方法对异步任务的结果进行处理,并返回新的CompletableFuture对象
        CompletableFuture<String> processedFuture = future.thenApply(result -> {
            System.out.println("对异步任务结果进行处理");
            return "处理后的结果:" + result * 2;
        });
        
        // 使用get方法阻塞当前线程,并获取异步任务的执行结果
        String result = processedFuture.get();
        System.out.println(result);
    }
}
异步任务正在执行
对异步任务结果进行处理
处理后的结果:200

到了这里,关于java 如何快速实现异步调用方法的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • java 异步执行代码(先返回结果,后执行代码)

            在用户那,角色那变更后,要更新数据,因为更新要比较长时间,需要先返回结果(2:已接收待执行)。更新结束后,再返回值结果。 (执行结果. 0:执行失败 ; 1:执行成功; 2:已接收待执行) 使用 ExecutorService 异步 加 Thread.sleep(1000 * 10); 就明显看得出差别了。

    2024年02月09日
    浏览(36)
  • Java高并发系列: 使用wait - notify实现高效异步方法

    在项目开发中, 通常会有异步执行操作, 例如: 提交一个异步清空一系列数据库中ID = ${_id} 的记录, 这个时候通常的做法是主线程将任务添加到一个异步队列中, 后台维护一个线程不断地 循环 扫描这个队列, 如果有需要执行的任务, 则执行相应的逻辑. 如下图所示: 代码实现如下

    2024年02月09日
    浏览(43)
  • JAVA的回调机制、同步/异步调用

    同步调用是最基本的调用方式。类A的a()方法调用类B的b()方法, 类A的方法需要等到B类的方法执行完成才会继续执行 。如果B的方法长时间阻塞,就会导致A类方法无法正常执行下去。 如果A调用B,B的执行时间比较长,那么就需要考虑进行异步处理,使得B的执行不影响A。通常

    2024年02月14日
    浏览(27)
  • Java中如何使用消息队列实现异步(ActiveMQ,RabbitMQ,Kafka)

    在 Java 中,可以使用消息队列实现异步处理。下面是一个简单的示例代码,用于说明如何使用 ActiveMQ 实现消息队列异步处理: 添加 ActiveMQ 依赖 在 pom.xml 文件中添加以下依赖: 创建消息队列 创建一个名为 “TestQueue” 的消息队列,并配置 ActiveMQ 连接信息: 创建消息消费者

    2024年02月16日
    浏览(46)
  • SpringBoot如何优雅的实现异步调用?

    Spring Boot 提供了多种方式来实现异步任务,这里介绍三种主要实现方式。 Spring Boot 提供了多种方式来实现异步任务,这里介绍三种实现方式。 @Async 注解是 Spring 提供的一种轻量级异步方法实现方式,它可以标记在方法上,用来告诉 Spring 这个方法是一个异步方法,Spring 会将

    2024年02月07日
    浏览(28)
  • 【SpringBoot系列】如何优雅地实现异步调用

    1.前言 在现代的应用程序开发中,异步调用是提高系统性能和响应能力的重要手段之一。 Spring Boot作为一个快速开发框架,提供了多种方式来实现异步调用,使得开发者能够更加优雅地处理并发和异步任务。 本文将介绍如何在Spring Boot中实现异步调用的方法和技巧,帮助开发

    2024年02月07日
    浏览(30)
  • 深入理解Spring的@Async注解:实现异步方法调用

    在当今高速发展的应用开发领域,对于提升系统性能和响应能力的需求越来越迫切。而异步编程作为一种解决方案,已经成为现代应用开发中的一项重要技术。本篇博客将带您深入探究 Java 中的 @Async 注解,揭示其强大的异步执行能力和精妙的实现机制。 异步编程是一种编程

    2024年02月05日
    浏览(34)
  • (线程池)多线程使用场景--es数据批量导入、数据汇总、异步调用;如何控制某个方法允许并发访问线程的数量;对ThreadLocal的理解及实现原理、源码解析、ThreadLocal的内存泄露问题

    CountDownLatch(闭锁/倒计时锁) 用来进行线程同步协作,等待所有线程完成倒计时(一个或者多个线程,等待其他多个线程完成某件事情之后才能执行) 其中构造参数用来初始化等待计数值 await() 用来等待计数归零 countDown() 用来让计数 减一 多线程使用场景一:( es数据批量导

    2024年04月25日
    浏览(40)
  • Java:Java程序通过执行系统命令调用Python脚本

    本文实现功能:Java程序调用Python脚本 直接执行 参考视频 JAVA开发必会小技巧8——用代码调用系统指令

    2024年02月14日
    浏览(49)
  • 【异步】Java 的 8 种异步实现方式

    异步执行对于开发者来说并不陌生,在实际的开发过程中,很多场景多会使用到异步,相比同步执行,异步可以大大缩短请求链路耗时时间,比如:发送短信、邮件。 异步的八种实现方式: 线程异步 Thread/Runnable Future + Callable 异步框架 CompletableFuture Spring 注解 @Async Spring App

    2024年02月10日
    浏览(27)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包