我有一些具有签名的静态方法，如下所示： ResourceUnavailableException我想把所有这些方法都包装在WebApplicationException中，这样我就可以在CompletableFuture.runAsync()中使用它们了。到目前为止，我得到了这样的东西： try {
浏览 7提问于2018-07-17得票数 0
回答已采纳
我正在研究Java 8 CompletableFuture (在Scala或JS等语言中的承诺)。private CompletableFuture<String> createFu
浏览 3提问于2015-05-15得票数 1
回答已采纳
1回答
例如，下面的方法调用返回一个将在给定通道上写入头的ChannelFuture。这些任务通常在上排队。boolean endStream,我注册了一个ChannelListener来处理失败时的异常Throwable cause = future.cause(); }以前，
浏览 28提问于2018-01-04得票数 0
1回答
我是可完成未来领域的新手。无论如何，我有一个基本的JPA应用程序，我想使用异步调用。但我不希望服务返回到可完成的未来。 return CompletableFuture.completedFuture(result);
我希望函数只返回可迭代的：distributorsRepository.findAll();
return CompletableFuture.completedFutu
浏览 15提问于2019-08-20得票数 0
你好，我正在构建一个带有react前端的REST应用程序，我遇到了一个问题，就是在执行剩下的所有方法之前，我得到了一个响应方式。所有方法均能在3~ 20 min内完成。我想要的是，无论花多长时间，我只想在一切都做好准备的时候发送回复。因为这是我第一次创建REST，所以我应该返回最后一个方法，或者什么是最佳实践？); System.out.println("HEJ
浏览 0提问于2018-04-11得票数 0
回答已采纳
我正在寻找一种非阻塞的方法来和一个CompleteableFuture<BigDecimal>流。
浏览 0提问于2019-04-25得票数 6
回答已采纳
我有一个Stream<Item>，我正在映射到一个CompleteableFuture<ItemResult>将所有期货收集到一个数组中，并使用CompleteableFuture.allOf()。这在一定程度上是有问题的，因为可能会有数十万个条目，所以只需继续使用forEach(CompleteableFuture::join)。这也是有问题的，因为使用join调用forEach只会阻塞流，它本质上是一
浏览 4提问于2021-08-31得票数 2
我以前有个可调用的课程 @OverrideSampleTask task = new SampleTask();
不存在变量U类型的实例，因此SampleTask符合供应商的要求
浏览 3提问于2017-05-03得票数 0
回答已采纳
);a1.complete(null);a3.complete(null);字符串测试是打印出来的。如何组合completableFutures，使一个completeExceptionally触发句柄方法？
浏览 13提问于2022-07-14得票数 1
回答已采纳
我在我的应用程序中非常有效地使用了ExecutorServices，它必须处理订单处理，现在订单生命周期有多个阶段，需要按顺序完成。而两个订单应该彼此独立处理。EnrichOrder(order); order = confirmOrder(order);} 另一方面，如果我使用CompleteableFuture，我看到的唯一优势就是使用通用的forkjoin池，其中<e
浏览 63提问于2019-10-09得票数 0
我有一个私人的Ethereum区块链与5台机器在上面采矿。到目前为止，块链的大小是300。处理是在后端Java上完成的。
List<Completea
浏览 0提问于2018-07-06得票数 3
回答已采纳
1回答
使用Servlet3.0，我们可以创建异步操作的任务，允许将处理请求的线程返回到容器，容器现在可以使用它处理另一个请求。如果我们使用线程池来配置可用于异步请求的线程数量，那么应该如何对其进行调优?throwable) -> deferredResult.setResult(result));与使用Callable的托管线程池方法相比看起来
浏览 1提问于2017-09-15得票数 1
回答已采纳
1回答
假设我在客户端Java应用程序(即Android应用程序)中有一个方法 /* IN A BACKGROUND THREAD */
CompleteableFuture<String> s = CompleteableFuture</e
浏览 49提问于2019-07-15得票数 1
在Quarkus中，使用小黑眼反应性消息传递的代码如下所示:用OutgoingKafkaRecordMetadata包装有效负载@Channel("test")
Emitter<byte []>示例描述了直接发送有效负载(即emitter.send(有效负载)返回CompletionStage但emitter.send(消息)返回空)时的过程，但这需要预先配置主题。是否可以使用消息指定元数据，并仍然以成功/失败的响应响应调用客户端？(我不介意它是与发射器、CompletionStage、Mun
浏览 5提问于2022-03-20得票数 0
回答已采纳
我不确定哪种方法是在数据库中设置新文档的最佳方法。
我假设这比第二种方法更快，但也存在一些文档/子集合不会被创建的风险。(我有更多被创建的文档，但是我只展示了一些简单<em
浏览 4提问于2020-05-14得票数 1
回答已采纳
我正试图从命令式的尝试和资源转移到反应式的尝试和资源，但没有成功。我有下面这段代码我想移动一下。s3Object.getObjectContent()); }).subscribeOn(Schedulers.boundedElastic());
浏览 17提问于2021-03-30得票数 1
回答已采纳
方法返回一个结果列表(异步)。我使用单个结果并对其进行进一步处理，以(异步)返回另一个结果。中使用它 如果可能的话，我想使用CompleteableFuture的链接。我还没有找到一种方法来做到这一点，也没有任何例子提到它。任何关于如何实现这一点的帮助或指示都将是非常有帮助的。PS:我已经设法使用两个独立的CompleteableFuture流解决了这个问题，但是，我想使用链式thenCompose List<String>
浏览 75提问于2021-01-04得票数 3
目的是为具有基于CompleteableFuture的异步操作的代码编写带有模拟的单元测试用例。在这里，我希望模拟具有completableFuture的源代码的单元测试。用于单元测试的源代码:-
public String getSomeRe
浏览 1提问于2019-09-03得票数 1
回答已采纳
1回答
假设我有一个返回CompleteableFuture[Data]的方法：而且，doIt()返回null的可能性是非零的在不阻塞调用线程的情况下，在结果不是doIt()之前，我们如何调用null？Scala的方法是什么？我目前的尝试是： var data: Data = null
blocking
浏览 1提问于2018-08-05得票数 1
回答已采纳
1回答
我正在实现一个Iterator，为了处理Exceptions，我使用了以下模式:实际工作是在私有hasNextPriv()方法中完成的，而hasNext()方法处理的是Exceptions。这样做的原因是因为我不想在hasNextPriv()上乱扔try-catch块。XMLStreamException e1) { } return false;问题：
有
浏览 3提问于2016-07-25得票数 0
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
