嵌套期货未执行
我遇到了一个奇怪的情况。我正在摆弄 CompletableFuture ，在运行以下代码时，我得到了意想不到的结果： public static void main（String [] args）{ CompletableFuture
..
completable-future相关内容
Java CompletableFuture的thenApply和thenApplyAsync有什么区别？
假设我有以下代码： CompletableFuture future = CompletableFuture.supplyAsync（（） - > 0）; thenApply 案例： future.thenApply（x - > x + 1） .thenApply（x - > x + 1） .thenAccept（x - >
..
Java 8 CompletableFuture，Stream和Timeouts
我正在尝试使用 CompletableFuture 和流 同时处理一些数据到目前为止我有： public static void main（String [] args）抛出InterruptedException，ExecutionException { System.out。的println（ “开始”）; List collect = Stream.of
..
Java Future - Spring Authentication在AuditorAware中为null
这是我的方案： 我的应用启用了Mongo审核，使用自定义AuditorAware从 SecurityContext获取当前用户。这适用于同步方法，并且当前审核员已成功保存，但我无法使用 @Async 方法使其正常工作。 我有一个异步方法（ CompletableFuture ），它对我的Mongo数据库进行了一些更新。当调用 AuditorAware.getCurrentAudit
..
您如何访问已传递给CompletableFuture allOf的已完成期货？
我试图掌握Java 8 CompletableFuture。我怎样才能将这些人加入到“allOf”之后再归还给他们。下面的代码不起作用，但让您了解我尝试过的内容。 在javascript ES6中，我会这样做 Promise.all（[ p1，p2]）。then（function（persons）{ console.log（persons [0]）; // p1返回值 conso
..
如何创建异步堆栈跟踪？
更新：最新版本的Intellij IDEA 实现正是我正在寻找的东西。问题是如何在IDE之外实现这一点（所以我可以将异步堆栈跟踪转储到日志文件），理想情况下不使用检测代理。 自从我将应用程序从同步模型转换为异步模型后，我遇到了调试失败的问题。 当我使用同步API时，我总是在异常堆栈跟踪中找到我的类，所以我知道从哪里开始查找是否出错。使用异步API，我得到的堆栈跟踪不会引用我的类，也不会
..
CompletableFuture：等待第一个正常返回？
我有一些 CompletableFuture s我希望并行运行它们，等待第一个返回正常。 我知道我可以使用 CompletableFuture.anyOf 等待第一次返回，但这将返回通常或格外。我想忽略例外。 列表> futures = names.stream（）。map（ （字符串名称） - > CompletableFuture.s
..
CompletionStage是否始终在CompletionException中包装异常？
CompletionStage Javadoc声明： [...]如果一个阶段的计算突然以（未经检查的）异常或错误终止，那么所有需要完成的依赖阶段异常完成，使用CompletionException将异常作为其原因。 看作异常完成总是在 CompletionException 为什么 exceptionally（）， whenComplete（）和 handle（）将异常表示为 Thro
..
CompletableFuture |然后应用vs thenCompose
我无法理解 thenApply（）和 thenCompose（）之间的区别。 那么，有人可以提供有效的用例吗？ 来自Java文档： thenApply（Function fn） 返回一个新的 CompletionStage 当这个阶段正常完成 时，执行此阶段的结果作为 提供函数的参数。 the
..
为什么CompletableFuture.supplyAsync成功随机次数？
我是Java 8中的lambdas和异步代码的新手。我不断得到一些奇怪的结果...... 我有以下代码： import java.util.concurrent.CompletableFuture; 公共类程序{ public static void main（String [] args）{ for（int i = 0; i
..
Java8 CompletableFuture recoverWith等价？例如，异常但返回CompletableFuture< U>
我没有看到使用异步结果处理异常的明显方法。 例如，如果我想重试异步操作。我希望这样的东西，但handleAsync不会做你认为它做的事情 - 它在异步运行另一个线程上的回调。在这里返回CompletionStage是不正确的。当天的危险问题：然后应用是异常的，然后组成是什么。 CompletionStage cf = askPong（“导致错误”）.thandAsync
..
使用CompletableFuture处理Java 8供应商异常
考虑以下代码 - public class TestCompletableFuture { BiConsumer biConsumer =（x，y） - > { System.out.println（x）; System.out.println（y）; }; public static void main（String args
..
CompletableFuture已经完成，但有例外
CompletableFuture.completedFuture （）返回已使用给定值完成的 CompletedFuture 。 我们如何构建已经异常完成的 CompletableFuture ？ 意思是，我希望将来抛出一个值，而不是返回一个值例外。 解决方案 我刚发现这个： CompletableFuture< T> future = new Compl
..
CompletableFuture的完成处理程序在哪个线程中执行？
我对CompletableFuture方法有疑问： public CompletableFuture< U> thenApply（函数 fn） 事情是JavaDoc说的只是这个： 返回一个新的CompletionStage，当这个阶段正常完成 时，执行此阶段的结果作为参数 提供的功能。有关特殊完
..
在定义API时我应该返回CompletableFuture还是Future？
在Java 8中，接口或抽象类更好地定义返回 CompletableFuture 的API，而不是返回 Future ？考虑到将 Future 转换为丑陋 CompletableFuture 以及 CompletableFuture 这一事实将使调用者更灵活地直接使用功能样式， API只是返回 Future 的一个很好的理由？ 解决方案 我的2 cts： 通过返回Future，您可以
..
使用CompletableFuture适应异常的正确方法
我正在链接CompletableFuture来适应例外。虽然我有一些工作，我不明白为什么它的工作。 @Test public void futureExceptionAdapt （）throws ExecutionException，InterruptedException { class SillyException extends Exception {} class Ada
..
从CompletableFuture投掷例外
我有以下代码： //如何抛出ServerException？ public void myFunc（）throws ServerException { //某些代码 CompletableFuture a = CompletableFuture.supplyAsync（（） - > { try { return someObj.someFunc（）; } catch（
..
Java 8供应商异常处理
考虑以下代码 - public class TestCompletableFuture { BiConsumer biConsumer =（x，y） - > { System.out.println（x）; System.out.println（y）; }; public static void main（String args
..
映射异常在未来的完整的不同的异常类型？
我正在使用java 8的完整期货，我希望能够在将来抛出一个例外，并将其转换为不同的异常。 一旦出现异常，我尝试的所有复合材料似乎都会短路。 使用例如，scala的未来，我可以这样做： scala.concurrent.Future translateException = ask.recover（new Recover（）{ @Overri
..
CompletableFuture＃whenComplete不被调用，如果thenApply被使用
我有以下代码（由我的上一个问题）在远程服务器上安排任务，然后使用 ScheduledExecutorService＃scheduleAtFixedRate 轮询它完成。任务完成后，它将下载结果。 我想向调用者返回一个 Future ，以便他们可以决定阻塞的时间和长度，并给他们选择取消任务。 我的问题是，如果客户取消由下载返回的 Future c>方法， whenComplete 块不执行。
..