腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
4
回答
在
Java
中
链接
可变
数量
的
承诺
(
CompletableFuture
)
java
、
promise
、
reactive-programming
、
future
、
completable-future
给定一个函数列表,其中Context是一些自定义类型: List<Function<Context,
CompletableFuture
<Context>>> preprocessors; 我需要得到一个执行了这些函数
中
的
每一个函数
的
CompletableFuture
<Context>,以便将每次迭代
的
异步结果提供给下一个迭代。因此,对于列表
中
包含3个元素
的
以下语句,我需要一个通用
的
解决
浏览 29
提问于2017-11-24
得票数 2
回答已采纳
1
回答
将Scala
的
未来与
承诺
转化为
Java
8 ComletableFuture
scala
、
java-8
、
promise
、
future
、
completable-future
我读过和,我知道这个概念是 我想知道如何使用
Java
8
CompletableFuture
来实现同样
的
目标,因为我认为
CompletableFuture
并没有像S
浏览 2
提问于2017-06-13
得票数 2
回答已采纳
1
回答
从回调
中
设置未来
java
、
concurrency
、
future
我想实现以下伪代码所说明
的
目标: Future res;Future res = executor.submit(...);res.get() 似乎不在这里工作。我也不能改变这样设置回调
的
事实。
浏览 3
提问于2016-01-06
得票数 7
回答已采纳
1
回答
使用
CompletableFuture
代替API
的
未来
java
、
asynchronous
我有机会在
Java
8
中
设计一些与异步数据存储相关
的
API。我希望我
的
方法返回
承诺
,即
CompletableFuture
而不是Future。然而,我还没有见过很多这样
的
API(但这可能是因为它们还没有
在
java
8上)。 考虑到
CompletableFuture
与简单
的
Future相比最终带来了这么多,这个决定是否明智?
浏览 1
提问于2014-12-11
得票数 1
回答已采纳
1
回答
CompletableFuture
从UI线程中等待UI线程?
java
、
multithreading
、
java-8
、
completable-future
Java
8
的
承诺
实现,即
CompletableFuture
,提供了thenApply(...)和get()方法。(请参见stackoverflow.com.see/)。如果我们
在
UI线程
中
也调用了行为,比如
Java
以某种方式处理这种情况,或者它会导致所谓
的</em
浏览 3
提问于2022-05-26
得票数 0
回答已采纳
1
回答
Java
在
另一个线程上实现任务,使用类似javascript
的
承诺
解决-拒绝
java
、
multithreading
、
networking
-我使用netty.io网络框架,它是一个非阻塞
的
框架,它处理同一线程上
的
所有连接。因为我不想造成任何延迟,所以我不会在同一个线程上发送HTTP请求,因为我不想停止它。相反,我遵循了一种回调模式,比如
java
脚本
承诺
解决--拒绝,我想听听您
的
想法,以及它是否可以做得更好。不要介意泛型类型,只需了解一下它
的
基本概念: 首先,这是我
的
ServiceProvider,这个类
的
目的是提供与微服务(如UserService服务器)交互
的
每个服务
浏览 0
提问于2019-12-30
得票数 1
回答已采纳
2
回答
当将数据保存到会话时,Spring异步函数异常
java
、
spring
、
spring-boot
、
asynchronous
我正面临一个关于@Async任务与HttpSession有关
的
问题。我希望将数据保存在会话
中
的
异步方法
中
。所发生
的
情况是正确返回响应,但我
在
会话中保存数据时会得到一个错误。请帮帮忙。我
的
控制器文件:@Controller private ISomeServicepublic String someFunc() { iSomeS
浏览 6
提问于2019-03-07
得票数 0
回答已采纳
2
回答
如何使用ExecutorService轮询直到结果到达
java
、
concurrency
、
future
、
executorservice
、
completable-future
一旦它完成,我将进行一个不同
的
调用来检索结果。当我第一次检测到远程任务已经完成时,我希望执行一个不同
的
远程调用,并将其结果设置为future
的
值。我想我可以为此使用
CompletableFuture
,我将转发到我
的
poll方法,后者会将它转发给最终会完成它
的
retrieveTask方法:
CompletableFuture
<Object> result相反,我认为我应该执行
CompletableFuture
.supplyAsync(() -
浏览 0
提问于2016-10-25
得票数 17
回答已采纳
2
回答
concatMap变量
承诺
量和管道结果作为下一个
承诺
的
参数
javascript
、
promise
、
rxjs
、
reactive-programming
、
rxjs5
我有一个
可变
数量
的
承诺
,我想按顺序执行它们,并将前一个
承诺
的
结果作为下一个
承诺
的
参数。= Rx.Observable.concat(...source$);但是,现在我如何才能将参数导入到每个
承诺
中
就像这样: Observable.from(p1).concatMap(res => p2(res)).concat
浏览 1
提问于2017-09-06
得票数 2
回答已采纳
3
回答
如何防止其中一个抛出异常时执行可运行程序
java
、
asynchronous
、
completable-future
我有一组元素,并对每个元素执行method,将其作为Runnable传递给
CompletableFuture
.runAsync()。
在
执行过程
中
,可能需要停止整个计算,所以我
在
执行方法之前检查了一些条件。如果计算应该停止,那么我抛出一个异常,该异常在
CompletableFuture
外部处理。我想阻止所有Runnables
的
执行,这些Runnables是
在
抛出异常之后执行
的
。因此,换句话说,我不想等待所有的CompletableFutures完成,当它
浏览 20
提问于2019-09-11
得票数 2
回答已采纳
3
回答
如何在
java
中
实现更改输出类型
的
承诺
java
、
promise
我试图用
java
实现一个简单
的
承诺
系统。我这样做是为了特殊目的,所以请不要推荐任何图书馆。当我试图实现一个以函数作为参数
的
thenApply()方法时,我遇到了一个问题,这类似于所拥有的,因此返回了另一种类型
的
承诺
。List<Consumer<T>> resultHandlers = new ArrayList<>(); public PromiseImpl(
CompletableFuture
<T> future
浏览 0
提问于2018-07-06
得票数 5
回答已采纳
1
回答
如何在Spring
中
缓存
CompletableFuture
的
值
java
、
spring-boot
、
completable-future
、
spring-cache
、
redisson
我试图
在
Spring
中
与
CompletableFuture
和Async一起玩。 ...
浏览 6
提问于2020-02-24
得票数 4
9
回答
从List<
CompletableFuture
>到
CompletableFuture
<List>
的
转换
java
、
concurrency
、
java-8
、
completable-future
我正在尝试将List<
CompletableFuture
<X>>转换为
CompletableFuture
<List<T>>。这是非常有用
的
,因为您有许多异步任务,并且您需要获得所有这些任务
的
结果。<List<Integer>> sequence = sequence2(que.collect(Collectors.toList()), executorService); 如果他们
中
的
任何一个失败了线程
中</e
浏览 6
提问于2015-05-04
得票数 89
回答已采纳
2
回答
在
Java
中
异步编程
的
“`CompletionHandler`”和“`
CompletableFuture
`”是两种不同
的
方法吗?
java
、
asynchronous
、
callback
、
future
简单地说就是用
Java
Com
浏览 9
提问于2017-10-18
得票数 2
1
回答
打破CompletableFutures链
java
、
asynchronous
、
future
、
completable-future
您可以像这样使用
CompletableFuture
链接
运行块: .supplyAsync(block1)}foo().thenApply(block3).join(); 我想在我
的
方法
中<
浏览 1
提问于2015-07-14
得票数 0
回答已采纳
1
回答
如何捕获
CompletableFuture
的
whenCompleteAsync调用
中
抛出
的
RejectedExecutionException?
java
、
java-8
、
future
、
executorservice
、
completable-future
在下面的示例代码
中
,我注入了一个休眠了100毫秒
的
biconsumer,作为一组可完成
的
未来
的
完成动作。我通过给出一个单独
的
executorService来使用whenCompleteAsync方法。ThreadPoolExecutor(5, 5, 10, ArrayList<
CompletableFuture
<Stri
浏览 32
提问于2017-02-22
得票数 5
回答已采纳
2
回答
返回原始方法
的
数据类型
java
例如,我有一个返回布尔值
的
方法,我在那里创建了一个新线程,很难在线程
中
返回布尔值。让我用这个例子向你展示我
的
意思: public boolean test() { int b = 3; int a = 5; new,有没有比thies更容易
的
方法
浏览 10
提问于2019-04-14
得票数 1
回答已采纳
1
回答
Java
相当于Scala
的
未来?
java
、
multithreading
、
scala
、
concurrency
我正在寻找与Scala
的
未来
在
Java
中等价
的
东西。我正在寻找一种类型
的
构造,它允许我将任务(Runnables / Callables)提交到我选择
的
特定线程池,返回期货,允许我
在
完成任务时(以非阻塞方式)
链接
到它。executor.submit(() -> { return 666;
Ja
浏览 7
提问于2020-12-16
得票数 0
回答已采纳
1
回答
CompletableFuture
全部以异步方式运行3个任务
spring
、
spring-boot
、
completable-future
在
我
的
应用程序
中
,我们将数据保存到事务块
中
的
表和ES
中
。表A(内部使用OneToMany) 如上所述,3是独立
的
操作,我想使用
CompletableFuture
.allOf(),但无法找到正确
的
示例。期望布尔值
在
返回201之前确保操作成功
浏览 3
提问于2017-11-29
得票数 1
3
回答
Java
11 HttpClient Http2太多流错误
concurrency
、
stream
、
http2
、
java-11
、
multiplexing
我正在使用
Java
11
的
HttpClient将请求发布到HTTP2服务器。HttpClient对象是作为Singleton创建
的
,如下所示。当我试图连续地访问服务器时,
在
"
java
.io.IOException:太多并发流“一段时间后,我会收到错误。我
在
客户端构建中使用了固定
的
线程池来尝试克服这个错误,但是它仍然给出了相同
的
错误。/
java
.util.concurrent.
CompletableFuture
浏览 16
提问于2019-02-28
得票数 10
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Java 11时代,这些编程习惯可以改一改了
异步线程CompletableFuture让你的代码速度快到飞起
携程基于Quasar协程的NIO实践
JDK7和8中关于ForkJoinPool的内存泄漏BUG
高德云图异步反应式技术架构探索和实践
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券