-
为什么CompletableFuture在单独的流中加入/获取速度要比使用一个流更快
对于以下程序,我试图弄清楚为什么使用2个不同的流并行处理任务,并使用相同的流并在Completable future -
是否可以安排CompletableFuture?
有什么办法可以安排Java中的CompletableFuture? 我要做的是安排要延迟执行的任务,并将其与其他操作链接 -
java 8 completablefuture在for循环中,强制异步同步或像链一样
当前,我需要执行异步任务以在completablefuture中进行同步。例如。任务A和任务B是不可替代的未来。当任 -
Future Cancel是否也会在数据库端终止Oracle查询
我正在使用Java Future类来执行连接Oracle数据库的程序。但是有时查询的速度比预期的要慢。我可以通过fut -
java8异步方法CompletableFuture.runAsync不运行
非常基本的代码可以运行异步方法。 当我运行以下代码时,runAsync无法运行。 我想念什么? 结果 -
在CompletableFutures的Future上获取方法
我正在用Java做一些多线程工作,我对Future <code>get</code>方法有疑问。 我有一个<code>ExecutorSevice</code -
将Promise.sequence(promises).map()转换为CompletableStage API
<strong>我已经查询但没有帮助的链接</strong> <ul> <li> <a href="https://stackoverflow.com/questions/56135121/is-there- -
当存在尚未完成的完成阶段时,为什么主线程不会终止?
这是我的简单代码: <pre><code>public class Main4 { public static void main(String[] args) { System.out.println( -
使用CompletableFuture Java重试请求
我遇到一种情况,我需要调用并行http请求来获取数据。 我已经使用CompletableFuture来获取数据,如下所示 -
为什么thenApply和thenApplySync无法在完成阶段使用 我知道
首先,很明显,我对<code>thenApply</code>不太了解,这就是为什么我遇到编译器错误,但我尝试搜索但无法 -
CompletableFuture依赖链可异步运行
我如何执行完整的CompletableFuture链以使用单独的执行程序异步运行 <pre><code> .thenApply(r -> { -
Java CompletableFuture然后由几个异步任务组成
我有一个由2个异步步骤组成的过程。第二步基于第一步的结果运行。该过程是循环启动的。挑战在于, -
CompletableFuture以异步执行多个数据库查询
我想并行执行多个数据库查询,并将结果存储在映射中。我正在尝试这样做,但是访问地图时,地图并 -
根据某些条件停止/完成循环的CompletableFuture
<pre><code>CompletableFuture<String> future = CompletableFuture.completedFuture(null); for(int _retrial = 1 ; _retrial <= getRetria -
将CompletableFuture与EJb一起使用时撞墙
我试图将CompletableFuture与在WildFly上运行的EBJ bean一起使用。 我可以看到调试器到达了远程Ejb并成功 -
通过终止ExecutorService可以解决的将来的问题
做一些基本的网络爬虫。 我想使用Completable future与多个线程并行运行抓取。每个作业都检索需要 -
CompletableFuture如何先返回FALSE或等到全部完成后再返回TRUE
我有点奇怪的情况,似乎不允许这种钉子固定在任何已广泛建立的CompletableFuture孔中。 <ul> <li>在评估 -
当一项任务异常完成时,CompletableFuture的allOf行为
在下面的代码中,<code>myCode</code>方法引发一个<code>InterruptedException</code>。我的假设是,发生这种情况的 -
CompletionStage,CompletableFuture无效-返回什么?
这是我的方法: <pre><code>public CompletionStage<Void> insert(List<HashAction> hashActionList) { if(!hashActi -
返回包含CompletableFutures列表的CompletableFuture
我正试图更快地调用多个API。 在下面的代码中,<code>// Import required modules const axios = require('axios -
为什么`parallelStream`比`CompletableFuture`实现更快?
我想通过某种操作来提高后端REST API的性能,该操作可以按顺序轮询多个不同的外部API并收集它们的响应 -
Spring Boot-从CompletableFuture返回的值,将在异步过程仍在执行时在主调用函数中使用
我有一个Submit方法,我从UI接收输入并将其保存在数据库中。但是我还需要在它们之间异步执行其他一些 -
在条件函数中返回CompletableFuture <Void>
我有一个用例,我必须从根据条件组成2个可完成期货的函数中返回<code>CompletableFuture<Void></code>。 -
如何使用Mockito对具有CompletedFeature <UserDefinedObject> .supplyAsync(()-> someMethodWithReturn()))的方法进行单元测试?
我有一个控制器类,带有方法something(),该类对同一类的两个不同方法进行调用,并将两个调用的结 -
ExecutionException-尝试使用CompletableFuture异步调用10个其他Rest服务时发生SocketTimeoutException
我有一个带有Spring 4.0.3.RELEASE的Java 8应用程序。从这个应用程序,我将请求异步发送到10个不同的Rest服务 -
我该如何跳过即将完成的期货
下面的代码段巩固了可完成的未来。下面的问题是我的某些期货交易异常顺利,因此总体上我的交易异 -
使用CompletableFuture进行异步计算,该计算为每个循环返回一个对象
我有一个RESTFul API,其响应包含很多字段。我需要在响应中添加其他字段,这些字段需要以异步方式从出 -
加入CompletableFutures
我最近一直在使用CompletableFuture,试图并行化持久的IO操作。返回之前,我必须等待所有事情完成,所以 -
对照值映射表验证JsonNodes列表(基于某些条件)的最佳方法是什么?
我有一个Map,其中包含对象的名称和ID。从我的服务中,我得到一个List,其中每个JsonNode都包含一个名称 -
使用CompletableFuture.runAsync()与ForkJoinPool.execute()
在不将<code>Executor</code>传递到<code>CompletableFuture.runAsync()</code>的情况下,使用公用<code>ForkJoinPool</code>。