completable-future

0热度

2回答

有： String getData(String key){ // Slow operation } CompletableFuture<String> getDataAsync(String key){ return CompletableFuture.supplyAsync(() -> getData(key)); } 是什么下面的区别？一） keyStrea

2热度

1回答

如何使用CompletableFuture打开并将列表中的所有结果收集到线程中？

我有一个字符串列表，对于他们每个人，我需要打开一个新线程并将所有信息收集到CompletableFuture中。这是我的迭代： for (String result: results) { candidateInfos.add(getCandidatesInfo(result)); } 我试图首次线程的执行情况和我将不胜感激一些帮助。

-1热度

3回答

使用2线程的更快输出

我想在我的Java程序中使用两个线程来处理一小部分。我需要给数据库第一次调用和第二次调用API，两次调用具有相同的输入，然后使用任何先前完成的线程的输出。这是我第一次用线程编程，我很困惑。我看过教程，他们主要解释如何用线程完成两件独立的事情，所以我有点迷路。有人可以帮助或重新指引我到他们可能有的任何有用的链接？到目前为止，据我了解，它应该看起来像这样吗？： Thread thread1 =

0热度

2回答

如何立即发送请求异步响应

我试图找到一种异步方式立即返回客户端请求响应。我只需要记录请求数据，调用新线程来请求其他服务器上的昂贵操作（一些后端操作）并且无需等待来自它们的响应立即返回200状态响应到客户端。在这一刻，我试图用CompletableFuture做到这一点，但我错过了一些东西。 package com.example.controller; import org.apache.logging.log4

3热度

1回答

如何执行一个CompletableFuture数组并编写它们的结果

我在调查Java 8 CompletableFutures并阅读（并且看到）我应该使用thenCompose而不是thenApply。我已经将我的代码转换为使用thenCompose但我有一种错误的感觉。这里是我的控制代码... final CompletableFuture<List<String>> extractor = get(htmlPageSource); @SuppressWa

1热度

1回答

未知原因的Maven测试顺序运行（多线程测试）

我有一个代码，严重使用CompletableFuture，我的同事做了一些测试。测试似乎通过我的机器，但在他的失败。我发现了错误（即使测试通过了我的机器），但我想确保我正确地修复了它，而不会打扰我的同事（运行测试）。由于某些原因，测试中的多线程代码会按顺序运行。我运行了测试是这样的： mvn test -Dtest=CompFutTest -DfailIfNoTests=false -Dp

0热度

2回答

如果我在CompletableFuture上使用thenCompose并指定它，我是否有2个CompletableFutures？

说我有一个像下面的情况： CompletableFuture<Object1> f1 = Class1.doSomething(); CompletableFuture<Object2> f2 = Class2.doSomethingElse(f1); boolean b = doAnotherThing(f2); 凡Class2中使用thenCompose（），并返回一个不同的对象类型

3热度

2回答

CompletableFuture多线程，单线程并发或两者兼而有之？

我刚开始研究Java的CompletableFuture，并对这是真正的异步（即同时运行在一个线程上）还是跨越多个线程（并行）有点困惑。例如，假设我想拨打1000个不同的服务电话。进一步假设每个服务调用都可以异步进行。当使用CompletableFuture时，JVM会创建1000个独立的线程（假设JVM允许这么多线程），或者在一个线程中执行所有这些请求？或者它是否做了一些？使用一些线程异步执行

0热度

1回答

CompletableFuture承诺＆Java反射

我正在使用一个服务，让我回到一个CompletableFuture承诺，事情是，我只能通过反射工作得很好的方法。但对待诺言的回归让我感到困惑。通常人们会使用这样一个CompletableFuture工作： promise.thenApply(returnValue -> { //do something with it }); 一个怎样做到这一点与反思？

1热度

1回答

如何欺骗CompletableFuture.complete（）在其他线程中运行dependents/stages？

CompletableFuture<Object> cf = new CompletableFuture<>(); cf.whenComplete((t, throwable) -> { System.out.println(Thread.currentThread().toString()); }); cf.complete(new Object()); 这将运行whenCo