java和CompletableFuture类的新特性。我的程序会运行，但不会向控制台返回任何内容。确信它是一个变量，没有打印出来，也没有赋值到某个地方，但是还没有弄清楚。我做错了什么？import java.io.BufferedReader;import java.io.InputStreamReade
浏览 45提问于2020-02-23得票数 0
2回答
我有这个：如何将其转换为其中:第二个流由第一个流中的每个列表中的每个和所有项组成我研究了thenCompose，但它解决了一个完全不同的问题，也就是所谓的“扁平化”。
如何才能以流的方式有效地完成这项工作，而不会阻塞或过早地消耗不必要的流项目？这是我到目前为止最好的<e
浏览 0提问于2019-10-13得票数 3
给定存储库类，它返回一个单独的：和返回浮点数的CompletableFuture：repository.find() CompletableFuture<
浏览 1提问于2019-12-02得票数 0
回答已采纳
3回答
我发现当没有完成时，CompletableFuture::join看起来像uninterruptible：}
在上述实现中，waitingGet(false)将忽略工作Thread的中断标志并继续等待。我想知道如何中断调用CompletableFuture::join的Thr
浏览 314提问于2017-05-29得票数 6
回答已采纳
Java8中引入的CompletableFutures为scala.concurrent.Future中可用的语言特性带来了一些特性，比如一元转换。两者有什么不同，为什么Scala开发人员更喜欢ScalaFuturessjava8 CompletableFuture？是否仍然有很好的理由通过scala.concurrent.Future桥在Java中使用akka.dispatch？
浏览 0提问于2015-02-18得票数 17
回答已采纳
我必须构建自定义类型的对象，并且在返回和填充对象之前有多次调用。 Address address,Member member){ CompletableFuture.runAsynccustomRequest);
populateMemberD
浏览 4提问于2019-08-01得票数 1
回答已采纳
1回答
我使用Spring框架(Version5.0.5.RELEASE)在Java1.8类中实现了一个异步方法： @Autowired(futureList).join();
}我正在尝试用JUnit和Mockito测试这个类。中单独运行它时，单元测试似乎是成功的，
浏览 3提问于2018-12-17得票数 8
回答已采纳
4回答
在C++中，可以使用延迟或异步启动策略启动线程。有办法在Java中复制这个功能吗？，它存储在通过std：：期货访问的共享状态中，异步将返回给调用方。推迟：
如果设置了延迟标志，则异步转换f和args.使用与std：：线程构造函数相同的方式，但不生成新的执行线程。相反，执行延迟评估:对std：：将来异步返回调用方的非时间等待函数的第一次调用将导致使用args的副本调用f的副本(作为
浏览 7提问于2021-01-26得票数 6
1回答
我正在尝试纠正一个@Hystrix方法，它返回一个CompltetableFuture<String>。Throwable t){}org.springframework.web.util.NestedServletException我在某个地方读到，我可能<em
浏览 0提问于2020-11-19得票数 2
在下面的示例代码中，我注入了一个休眠了100毫秒的biconsumer，作为一组可完成的未来的完成动作。我通过给出一个单独的executorService来使用whenCompleteAsync方法。<String>> list = new ArrayList<>();
CompletableFuture<String> stringCompletable
浏览 32提问于2017-02-22得票数 5
回答已采纳
为什么这段代码在Java 8和Java 11中的行为不同？Finish，然后用500 ms间隔打印数字从1到20，然后停止执行，它在Java 8中正确工作。但是，当我在Java 11上运行完全相同的方法时，它打印Finish并在不调用runAsync(.)的情况下终止代码。我想出了如何在返回之前调用executorService.shutdown();来停止执行，但我100%肯定这
浏览 10提问于2021-04-19得票数 8
回答已采纳
我不明白CompletableFuture/supplyAsync在这里发生了什么。为了使它运行，我需要将一个complete(my value)放在supplyAsync的主体中。但是--如果我在创建CompletableFuture时直接调用supplyAsync (或者通过调用静态CompletableFuture.supplyAsync)：
public static void您可以在这里看到<em
浏览 1提问于2018-02-21得票数 2
<Integer> testFuture = CompletableFuture.supplyAsync(numberSupplier).whenComplete(biConsumer);然而，在我的例子中，sendNumbers也可能抛出一个检查过的异常，比如： public static Integer sendNumbers()throws Exception {
return 25; // just for work
浏览 2提问于2015-03-10得票数 8
我试图在WebSockets上用Java实现一个简单的RPC类(或请求响应)系统(前端将有JS，但目前我正在做后端的工作)。我正在尝试应用Java CompletableFuture模式来处理异步发送消息。但我现在被错误处理困住了。我有一个类(让我们称之为rpc类)，它负责通过WebSocket会话发送消息(这里使用Spring WebSocket支持类<
浏览 3提问于2016-09-15得票数 3
1回答
我在mariadb中有以下列定义：在我的实体类中，我有以下列：我已经指定了精度，但是保存在表中的数据仍然被限制为最多5位小数。我记录了itemMultiplier的值，它是0.458327459574。但是在<
浏览 4提问于2019-12-13得票数 0
2回答
我试着用Spring做一个小小的休息。我很久以前从未使用过Spring，也从未使用过Java (Java 7)！在过去的两年中，我只使用了Python和C# (但正如我所说的，我已经使用了Java)。所以，现在，我正在尝试使用异步方法进行休息，并检查了几个示例，但是，我仍然不太清楚实现这个目的的“正确方法”。如果我</e
浏览 7提问于2017-08-03得票数 29
回答已采纳
导入java.util.concurrent.CompletableFuture；类CF {静态空doSomething() { ..}静态CompletableFuture printAsync(inti) {返回CompletableFuture.runAsync(() -> { doSomething()；System.out.print(i)；})；}公共静态空洞主(string[] argsprintAsync(4))；剂量()；}
如果main正常运行，程序可能打印的<
浏览 2提问于2020-05-05得票数 0
我最近一直在使用CompletableFuture，并且发现，我们应该始终使用定制的线程池。通过它，我找到了两种将线程池传递给现有代码的方法。就像下面@Overridepublic Executor getAsyncExecutor() {
return new ThreadPoolTaskExecu
浏览 0提问于2019-05-19得票数 11
回答已采纳
我正在尝试实现CompletableFuture，它在完成时调用一个虚拟回调方法。 但是，在添加CompletableFuture.get()方法之后，我的主类并没有终止。我尝试用Thread.sleep(5000)替换CompletableFuture.get()，但它似乎不是正确的方法。请建议是什么原因导致CompletableFuture.get()在线程完
浏览 84提问于2019-06-15得票数 0
2回答
我正在使用MDC Logger，除了一个例子外，它非常适合我。在我们使用CompletableFuture的代码中，对于创建的线程，MDC数据不会被传递到下一个线程，并且由于日志失败。例如，在下面的代码片段中，我使用了创建新线程的方法。CompletableFuture.runAsync(() -> getAcountDetails(user));2019-04-29 11
浏览 0提问于2019-04-29得票数 2
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
