首页
学习
活动
专区
工具
TVP
发布
社区首页 >问答首页 >thenApply和thenApplyAsync of Java CompletableFuture有什么区别?

thenApply和thenApplyAsync of Java CompletableFuture有什么区别?
EN

Stack Overflow用户
提问于 2017-11-25 18:37:44
回答 4查看 30.3K关注 0票数 79

假设我有以下代码:

代码语言:javascript
复制
CompletableFuture<Integer> future  
        = CompletableFuture.supplyAsync( () -> 0);

thenApply案件:

代码语言:javascript
复制
future.thenApply( x -> x + 1 )
      .thenApply( x -> x + 1 )
      .thenAccept( x -> System.out.println(x));

这里的输出是2,如果是thenApplyAsync的话

代码语言:javascript
复制
future.thenApplyAsync( x -> x + 1 )   // first step
      .thenApplyAsync( x -> x + 1 )   // second step
      .thenAccept( x -> System.out.println(x)); // third step

我在这个博客中看到,每个thenApplyAsync都是在一个单独的线程中执行的,并且“同时执行”(这意味着在thenApplyAsyncs完成之前执行thenApplyAsyncs ),如果是这样的话,如果第一步没有完成,那么第二步的输入参数值是多少?

如果第二步不采取,第一步的结果将如何?第三步将采取哪一步的结果?

如果第二步必须等待第一步的结果,那么Async的意义是什么?

这里,x -> x+1只是为了说明这一点,我想知道的是在非常长的计算情况下。

EN

Stack Overflow用户

发布于 2018-07-27 15:04:06

你错误地引用了文章的例子,所以你错误地应用了文章的结论。我在你的问题中看到两个问题:

.then___() 的正确用法是什么

在本文中引用的两个示例中,第二个函数必须等待第一个函数完成。无论何时调用a.then___(b -> ...),输入b都是a的结果,无论是否使用名为Async的方法,都必须等待a完成。这篇文章的结论不适用,因为你错引用了它.

本文中的例子实际上是

代码语言:javascript
复制
CompletableFuture<String> receiver = CompletableFuture.supplyAsync(this::findReceiver);

receiver.thenApplyAsync(this::sendMsg);  
receiver.thenApplyAsync(this::sendMsg);  

注意,thenApplyAsync都应用于receiver,而不是链接在同一个语句中。这意味着两个函数都可以在receiver完成后以未指定的顺序启动。(任何顺序假设都取决于实现。)

更清楚地说,

a.thenApply(b).thenApply(c);表示顺序是a完成,然后是b启动,b结束,然后是c启动。

a.thenApplyAsync(b).thenApplyAsync(c);a b c之间的排序方面将与上面的行为完全相同。

a.thenApply(b); a.thenApply(c);的意思是a完成,然后bc可以按任何顺序开始。bc不需要等待对方。

就订单而言,a.thenApplyAync(b); a.thenApplyAsync(c);的工作方式是相同的。

在阅读下面的内容之前,你应该了解上面的内容。上面提到的是异步编程,如果没有异步编程,您将无法正确地使用API。下面涉及线程管理,您可以使用它优化程序并避免性能缺陷。但是,如果不正确地编写程序,就无法优化程序。

名为:thenApply thenApplyAsync of Java CompletableFuture?之间的差异

我必须指出,编写JSR的人肯定混淆了“异步编程”这一技术术语,并选择了现在混淆新手和老手的名字。首先,thenApplyAsync中没有什么比这些方法的契约中的thenApply更异步的了。

两者之间的区别与在哪个线程上运行函数有关。提供给thenApply 可以在任何线程上运行。的函数

  1. 调用complete
  2. 在同一个实例上调用thenApply

thenApplyAsync的2个重载

  1. 使用默认的Executor (a.k.a )。),或
  2. 使用提供的Executor

对于thenApply,运行时承诺最终使用一些您无法控制的执行器运行您的函数。如果要控制线程,请使用异步变体。

如果您的函数是轻量级的,那么哪个线程运行您的函数并不重要。

如果您的函数是沉重的CPU绑定,则不希望将其留给运行时。如果运行时选择网络线程来运行您的函数,则网络线程无法花费时间来处理网络请求,从而导致网络请求在队列中等待更长时间,而您的服务器将变得没有响应。在这种情况下,您希望在自己的线程池中使用thenApplyAsync

有趣的事实:异步!=线程

thenApply/thenApplyAsync及其对应的thenCompose/thenComposeAsynchandle/handleAsyncthenAccept/thenAcceptAsync都是异步的!这些函数的异步性质与异步操作最终调用completecompleteExceptionally这一事实有关。这个想法来自Javascript,它确实是异步的,但不是多线程的。

票数 40
EN
查看全部 4 条回答
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/47489338

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档