所以我有一个接口SetupTask，它只有一个返回CompletableFuture的方法run()。我有一台List<SetupTask>。我想运行第一个，完成后运行第二个，完成后运行第三个，依此类推。最初，我尝试使用CompletableFuture.allOf()，但这将使它们全部并行运行。
浏览 17提问于2018-02-26得票数 2
我有executeGetCapability方法，它在不同的线程中执行，但是这些线程运行，sequentially..meaning一个接一个地完成public CapabilityResponseDTO getCapabilities(final List<String> ids) {
final CapabilityResponseDTOresp
浏览 6提问于2022-11-30得票数 1
我有一个问题，循环中的CompletableFuture任务不是并行运行的，而是同步运行的： int numberOfTasks = filesLists.size();
List</
浏览 0提问于2020-11-22得票数 1
1回答
使用可完成期货的实体处理列表
、、、、
我有一个T类型的实体列表。我还有一个函数接口，它充当Supplier，它的方法是对实体执行performTask操作，然后返回结果R，如下所示：
R performTask(T entity) throws Exception。我在实体列表上循环，然后一个接一个地处理它们可完成的未来，我认为这不是正确的方法。你们能建议一下这里可以做些什么吗？private void updateResultAndExceptionMaps(List < T > entities, final
浏览 0提问于2019-04-17得票数 1
我必须运行多个外部调用操作，然后以列表的形式获得结果。我决定使用CompletableFuture api，我编写的代码非常令人作呕：public class Main { String prefix = "collection_";
List<CompletableFuture<User>> usersResult =| ExecutionExce
浏览 5提问于2017-10-30得票数 7
回答已采纳
目前，我已经通过将第二个查询嵌套在第一个查询之后，让它们一个接一个地运行。有没有办法在不嵌套它们的情况下做到这一点？customers -> { //Update ui for query B });
public CompletableFuture<ObservableList<Appointment>>
浏览 39提问于2021-08-25得票数 1
回答已采纳
1回答
我用lamba和并行流做了一个POC：list.add(() -> {call1()});list.add(() -> {call3()}); .forEach(Runnable
浏览 0提问于2018-09-20得票数 10
回答已采纳
我有一个SOAP调用，需要进行调用，然后在REST调用中处理SOAP调用的结果。每组呼叫都基于一批记录。我完全迷失在尝试让它使用尽可能异步的JDK8流来运行。我怎样才能做到这一点？SOAP调用：{ }, EXECUTOR_THRE
浏览 0提问于2020-05-22得票数 0
回答已采纳
// Collect those as list .stream()(task, executorService)) // map to Com
浏览 11提问于2020-05-10得票数 1
回答已采纳
1回答
我有一些使用CompletableFuture运行异步的流，例如： .thenAccept(aaa -> {这在CompletableFuture中是可能的吗？编辑
使用CompletableFuture，您可以定义异步任务流，这些任务是一个接一个地执行的。例如，您可以说
浏览 0提问于2015-06-29得票数 5
回答已采纳
1回答
如何连锁可完成的期货
、、、、
这些调用并不是相互依赖的，但是当我想用completableFuture链接它们时，它们必须按照给定的顺序一个接一个地运行。update-> insert -> delete
调用不返回任何内容，因此我使用runAsync和thenRun方法的completableFuture。并相应地用链子拴住了他们。我正在迭代msgIds，这是一个字符串列表。msgIds.stream().forEach(msgId -> <e
浏览 2提问于2019-08-09得票数 7
3回答
Java 8并行运行多个方法
、、、、
我有两个方法，它们有不同的返回类型，我想同时运行它们。下面是我的代码： final CompletableFuture<List<FooA>> fooACF = CompletableFuture.supplyAsync(() -> generateFooA(id));
final CompletableFuture<List<FooB>> fooBCF = <
浏览 0提问于2017-11-21得票数 3
回答已采纳
我有两个CompletableFutures和三个方法，这些方法必须一个接一个地发生。但是，在某些情况下，没有必要使用第二种方法。CompletableFuture<Boolean> cf1 = supplyASync.(() ->( doSomething1()));
浏览 0提问于2018-03-19得票数 2
1回答
我有一个Spark应用程序选择一个子集并对该子集执行一些操作。每个子集和它的操作之间没有依赖和交互，所以我尝试使用多线程来让它们并行运行，以提高性能。sparkSession.read().json("some_path");List(CompletableFuture[]::new);
CompletableFuture.allOf(futur
浏览 16提问于2019-06-16得票数 0
回答已采纳
2回答
我必须通过调用rest从某个地方转储数据，该API返回List。
这是大约一个小时的6000条记录的第一步。
浏览 2提问于2019-03-23得票数 0
我正在尝试将List<CompletableFuture<X>>转换为CompletableFuture<List<T>>。这是非常有用的，因为您有许多异步任务，并且您需要获得所有这些任务的结果。如果其中任何一个失败了，那么最终的未来就会失败。我就是这样实施的：
public static <T> CompletableFuture<List<T>> sequence2(List
浏览 6提问于2015-05-04得票数 89
回答已采纳
为此，我使用了CompletableFuture和Guava。下面是我的尝试。在Java 8和线程API中是否有其他标准方法来实现相同的功能呢？public static List<String> returnAPIResponse(Integer key) { }
List
浏览 3提问于2021-01-16得票数 1
回答已采纳
我有以下代码： return foo; // some custom object.thenAcceptneed to spawn N async parallel jobs that works on 'foo'第一个任务异步创建foo对象，然后我需要在它上运行N个并行进程。CompletableFuture[] parallel = new Compl
浏览 4提问于2016-06-15得票数 3
回答已采纳
我认为新的java8 CompletableFuture将能够使用"thenComposeAsync“方法一个接一个地执行异步任务，而不会阻塞线程。如果nThreads <= 2，下面这段代码永远不会执行“Task3”：int nThreads= 2;
Executor e= Executors.newFixedThread
浏览 1提问于2014-04-14得票数 3
3回答
获得完全未来的结果
、、、、
在springboot应用程序中，我使用从异步线程返回的completablefuture。我的执行情况如下。根据我的理解，应该为列表中的每一项启动一个新线程，并且应该并行处理。我知道.get会阻止执行，但是由于它是并行运行的，所以在性能上没有任何改善。请您对下面的工作提出改进意见吗？ServiceA.javaServiceB serviceb;
L
浏览 6提问于2020-03-10得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
