怎么通过 CompletableFuture.delayedExecutor() 在指定的延时时间后触发后续的异步操作

落雪吖_4015

落雪吖_4015

2026-05-01

811人浏览

原创

completablefuture.delayedexecutor()仅创建延迟执行的线程池,需作为第二个参数传给supplyasync或runasync才能实现延时异步操作,返回值为executor而非completablefuture。

怎么通过 completablefuture.delayedexecutor() 在指定的延时时间后触发后续的异步操作

CompletableFuture.delayedExecutor() 本身不会“触发后续操作”,它只是创建一个**延迟执行任务的线程池(ScheduledExecutorService 的封装)**,你需要把它作为执行器显式传给 supplyAsync、runAsync 等方法,才能实现“延时后执行异步逻辑”。

核心用法:配合 supplyAsync / runAsync 使用

delayedExecutor 返回的是 Executor,不是 CompletableFuture。必须把它作为第二个参数传入异步方法中:

  • CompletableFuture.supplyAsync(() -> doSomething(), delayedExecutor(3, TimeUnit.SECONDS)) → 延迟 3 秒后异步执行并返回结果
  • CompletableFuture.runAsync(() -> doSomethingElse(), delayedExecutor(500, TimeUnit.MILLISECONDS)) → 延迟 500 毫秒后异步执行无返回值操作

常见组合:延时 + 链式处理(thenApply / thenAccept)

延迟执行的是“第一个异步任务”,后续的 thenXXX 方法默认在前一个任务完成的线程上执行(可能不是你期望的线程)。如需控制后续执行线程,可显式指定执行器:

  • 只对首步延时,后续立即链式执行(默认行为):
    supplyAsync(() -> "hello", delayedExecutor(2, SECONDS))<br>  .thenApply(s -> s + " world")<br>  .thenAccept(System.out::println);
  • 全程控制线程(比如都走自定义线程池):
    Executor customPool = Executors.newFixedThreadPool(4);<br>supplyAsync(() -> "hello", delayedExecutor(2, SECONDS))<br>  .thenApplyAsync(s -> s + " world", customPool)<br>  .thenAcceptAsync(System.out::println, customPool);

注意点:延迟精度与线程资源

delayedExecutor 底层基于 ScheduledThreadPoolExecutor,延迟时间是近似值,受系统负载和调度影响;它内部会创建一个单线程的调度器(除非你传入自定义 ScheduledExecutorService),所以高并发下大量延迟任务可能排队。如需更高吞吐,建议复用已有的 ScheduledExecutorService:

  • 复用已有调度器:
    ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);<br>supplyAsync(() -> work(), CompletableFuture.delayedExecutor(1, SECONDS, scheduler));
  • 避免频繁创建:delayedExecutor 每次调用都会新建一个轻量级代理,但底层调度器复用更高效

替代方案对比(什么情况下不用 delayedExecutor)

如果只是想“等几秒再继续”,且不关心是否异步执行,用 thenCompose + CompletableFuture.delayedExecutor 封装的休眠更清晰:

  • 纯等待(不消耗线程):
    CompletableFuture.delayedExecutor(3, SECONDS).execute(() -> { /* 后续逻辑 */ }); —— 但这不是 CompletableFuture 链
  • 推荐链式等待写法:
    CompletableFuture.completedFuture(null)<br>  .thenCompose(v -> CompletableFuture.<void>supplyAsync(() -> {<br>    Thread.sleep(3000); return null;<br>  }, delayedExecutor(0, NANOSECONDS)))<br>  .thenRun(() -> System.out.println("3秒后执行")); // 注意:sleep 在异步线程里,别阻塞主线程</void>
PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

2023.06.15

9977

6

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

2023.07.05

7122

9

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

2023.07.31

6272

8

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.01

1084

3

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.02

908

3

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

1316

5

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

2629

5

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

2023.08.03

19951

3

配置java环境变量
配置java环境变量

配置Java环境变量是为了让操作系统能够识别和使用Java的相关命令和功能。本专题为大家提供配置java环境变量相关文章,帮助大家解决问题。

2023.08.03

1175

8

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
热门推荐
/
最新课程
phpStudy极速入门视频教程
phpStudy极速入门视频教程

共6课时 | 54.6万人学习

独孤九贱(4)_PHP视频教程
独孤九贱(4)_PHP视频教程

共89课时 | 133.4万人学习