CompletableFuture<String> future = CompletableFuture.completedFuture(null); } });return future;
我最近开始在上面的代码中完成期货的工作-正如你所看到的，我正在用一个for循环</
浏览 23提问于2019-11-21得票数 1
回答已采纳
1回答
我有无限的承诺队列(可完成的未来)作为输入。目标是一个接一个地运行承诺，直到结果满足条件，停止对当前承诺的处理和返回结果。CompletableFuture<Integer> result = promisesQueue.poll().get();
resultshouldKeepReading) {
return promisesQueue.poll().get(
浏览 6提问于2021-12-07得票数 4
回答已采纳
3回答
我有一组元素，并对每个元素执行method，将其作为Runnable传递给CompletableFuture.runAsync()。在执行过程中，可能需要停止整个计算，所以我在执行方法之前检查了一些条件。如果计算应该停止，那么我抛出一个异常，该异常在CompletableFuture外部处理。我想阻止所有Runnables的执行，这些Runnables是在抛出异常之后执行的。因此，换句话说，我不想等待所有的CompletableFutures完成，当它
浏览 20提问于2019-09-11得票数 2
回答已采纳
这些任务的响应类型是布尔型。在从任何一个任务接收第一个false时返回。所有4个任务都已完成，没有一个任务返回false。我的项目是使用Java，springbootimport java.util.List;
import java.util.concurr
浏览 3提问于2021-06-09得票数 0
我想向不同的外部服务部门打平行电话，并进行第一次成功的响应。
在这里成功意味着服务返回的结果在某些字段中具有某些值。然而，对于CompletableFuture来说，除了例外之外，其他一切都是成功的。因此，即使对于业务失败，我也不得不抛出一个异常，向CompletableFuture发出不成功的信号。我遇到的第二个问题是，如何确保我不会因为放弃的CompletableFuture而
浏览 6提问于2022-05-24得票数 1
我有以下代码： return foo; // some custom object.thenAccept那么，是否有更好的方法来做到这一点：for (int i = 0; i < N; i++) {
parallel[i] = CompletableF
浏览 4提问于2016-06-15得票数 3
回答已采纳
我有一个可完成的未来定义如下现在，根据特定条件，我需要检查并执行对getPersons的调用，直到条件匹配或重试次数(5次重试，5秒间隔)结束为止。条件是 retry(personService
浏览 9提问于2022-04-15得票数 0
回答已采纳
我试图使用CompletableFuture并行执行for循环。在循环中，我使用supplyAsync调用doSomething获取输出字符串，然后将其放入HashMap中： completableFuture = CompletableFuture }
String result = processQueueAndRetur
浏览 7提问于2020-12-31得票数 0
回答已采纳
1回答
我构建了以下演示代码来测试java.util.concurrent.CompletableFuture.runAsync函数：import java.util.List(2);}); //"+RunningTasks.isEmpty());}
如果我在正常模式
浏览 0提问于2018-10-19得票数 2
回答已采纳
3回答
停止调用JNI函数的Java线程
、、、、
在这里，我想停止我的线程或者关闭在Java层上创建的线程，这个线程正在调用JNI函数。有时，根据我的应用程序需求，我必须在某些条件下停止JNI函数的执行，如果它正在执行，否则就不会。function call, It calls my JNI layer C function. }
现在，当这个线程执行开始并且它在JNI级别上工作时，我对此并不担心，但是在某些条件下，从其
浏览 13提问于2013-02-07得票数 5
回答已采纳
我正在尝试根据特定条件找到跳过CompletableFuture的方法。例如 CompletableFuture<T> preFetchCf = get(id);CompletableFuture<Boolean> cf1 = execute();
/*This is where I want differen
浏览 0提问于2018-02-03得票数 1
通常，在使用CompletableFuture时，我会调用thenApply或其他方法，以便在结果可用时立即执行某些操作。如果我只想获得第一个可用的结果，我可以使用CompletableFuture.anyOf (尽管我不喜欢仅仅为了调用anyOf就必须将列表转换为数组)。但这不是我想要的。我想要第一个结果，如果它没有一个理想的结果，那么我想处理第二个可用的结果，以此类推，直到我得到一个理想的结果。
下面是一个简单的示例，它遍历所有结
浏览 3提问于2016-04-14得票数 7
回答已采纳
我正在尝试用mockito测试CompletableFuture.supplyAsync函数，但是测试还没有完成，可能是因为可完成的未来没有返回。我不知道我在代码中遗漏了什么。有人能帮忙吗。我写的代码如下。因此，有返回用户的UserService类，返回用户实体的UserEntityService类，以及检查实体是否属于用户的验证类。
我想测试所传递的实体是否属于用户。validationService.validateUserCou
浏览 27提问于2022-08-12得票数 0
回答已采纳
.
// so}
我也读过关于的文章，但是routingContext是另外一些东西，这个例子是关于单元测试的.您有之间集成的示例吗?还是必须使用RxJava？
浏览 5提问于2017-09-28得票数 0
回答已采纳
我正在用java做一些多线程工作，我有一个关于未来get方法的问题。
我有一个提交n个可调用的ExecutorSevice。提交返回一个添加到列表中的Future (稍后在某些代码中)。可调用的call方法循环遍历一个列表，对于列表的每一项，调用someMethod并返回一个CompletableFuture<T>。然后，将可完成的未来添加到地图中。在循环的末尾，cal
浏览 4提问于2019-11-06得票数 1
回答已采纳
比方说，根据某些条件，您的应用程序动态地获取一些脚本。该操作是同步的还是阻塞的，例如任何正在进行的HTML呈现停止，还是异步完成？
浏览 4提问于2014-11-21得票数 1
回答已采纳
我有一个需求，需要获取AWS Glue crawler的状态，这是一个异步请求，根据作业完成的时间，我会触发某些事件。这里的问题是我不想使用轮询。进一步看，亚马逊网络服务文档建议使用CompletableFuture对象来处理亚马逊网络服务中的异步请求。但当我尝试使用时，我无法形成CompletableFuture对象，因为它使我的类型不匹配。<GetCrawlerMetricsResult> futur
浏览 0提问于2018-05-16得票数 0
1回答
}catch (ExecutionException | InterruptedException e) { }}; 我是这样开始的：_asyncTask = CompletableFuture.runAsync(task); 稍后我想要完成它 if ( _asyncTask != null ) { _asyncTask = null;
} 我看到了_asyncTask.isDone() == true，但它
浏览 7提问于2020-08-25得票数 0
我对某些脚本具有只读访问权限，这些脚本可能会运行数小时。不幸的是，环境权限只允许我使用任务调度器，并且当脚本运行时的某个条件为真时，我经常需要停止脚本运行，此时脚本必须立即停止。我需要停止该任务的继续do，while/until不起作用，因为它们是循环，会让整个脚本结束，而不是根据条件停止。
浏览 2提问于2018-12-28得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
