completable-future 相关问题

在Java 8中，可以显式完成的Future（设置其值和状态），并且可以包括在完成时触发的依赖函数和动作。

这是我的第一篇文章，我是 CompletableFuture 的初学者，我想在使用 CompletableFuture.get() 时测试异常（InterruptedException 和 TimeoutException）。我的代码：完整的未来...

java completable-future java.util.concurrent

回答 1 投票 0

Arjuna，表示一个动作用多个线程完成，并且其中一个线程正在进行中

我有这个应用程序，使用 applyAsync 方法我从其他服务获取数据，然后尝试保存在我们的数据库中，这个过程可以同时完成，我的意思是我请求数据它开始工作...

java multithreading quarkus completable-future quarkus-panache

回答 1 投票 0

CompletableFuture.supplyAsync() 是否多余，以防它不修改传入值？

在并发编程课程中，我遇到了以下示例代码： @测试 void PromiseTestCompose2() 抛出异常 { CompletableFuture future1 = CompletableFuture .

java concurrency completable-future java.util.concurrent

回答 1 投票 0

CompletableFuture.supplyAsync() 在不修改传入值的情况下是否冗余

在学习并发编程课程时，我遇到了以下示例代码： @测试 void PromiseTestCompose2() 抛出异常 { CompletableFuture future1 = CompletableFuture .

java concurrency completable-future java.util.concurrent

回答 1 投票 0

CompletableFuture 的误解

我似乎在 CompletableFuture 的一个看似简单的示例中惨遭失败。我有一个 CompletableFuture 被阻塞在不同的线程中，如下所示：供应商我似乎在一个看似简单的例子中惨败，CompletableFuture。我有一个 CompletableFuture 被阻塞在不同的线程中，例如： Supplier<CompletableFuture<String>> one = () -> CompletableFuture.supplyAsync(() -> { System.out.println("started cf"); LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(3)); System.out.println("done cf"); return ""; }); ExecutorService service = Executors.newSingleThreadExecutor(); service.submit(() -> { try { future = one.get(); future.get(); } catch (Exception e) { System.out.println("caught"); future.completeExceptionally(e); } }); 我希望能够cancel它，然后join等待它在与上面的线程不同的线程中完成，所以像这样： static CompletableFuture<String> future; public static void main(String[] args) { Supplier<CompletableFuture<String>> one = () -> CompletableFuture.supplyAsync(() -> { System.out.println("started cf"); LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(3)); System.out.println("done cf"); return ""; }); ExecutorService service = Executors.newSingleThreadExecutor(); service.submit(() -> { try { future = one.get(); future.get(); } catch (Exception e) { System.out.println("caught"); future.completeExceptionally(e); } }); LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1)); future.cancel(true); System.out.println("before join"); String s = future.join(); System.out.println("s value : " + s); System.out.println("done"); } 令我惊讶的是，这个String s = future.join();会阻塞，我不明白为什么。更令人惊讶的是，如果我将代码更改为（而不是String s = future.join();）： String s = null; try { s = future.join(); } catch(Exception e) { System.out.println("here : " + e.getClass()); } 这个不会阻塞。有人可以在这里解释一下吗？无论有或没有 try/catch 周围的 future.join() 这对我来说都是以同样的方式阻塞的，我在这里将“阻塞”定义为：我将代码放入文件中，从命令行运行它，并且该过程不会完成. 原因是 Executors.newSingleThreadExecutor() 使用非守护线程，这意味着即使 main() 方法返回，池的线程也会继续运行（您应该看到“完成”输出）。因此程序的进程没有完成。你也可以在 service.shutdown() 或之前调用 future.join() 或其一些变体使用变体 newSingleThreadExecutor(ThreadFactory)，其中线程工厂提供守护线程 (.setDaemon(true))

java completable-future

回答 1 投票 0

CompletableFuture.allof() 获取空指针异常

我的结构类似于下面的代码块。不知何故，我在 CompletableFuture.allOf 方法中得到 nullpointerException：这里可能有什么问题？谢谢.. 列表我的结构类似于下面的代码块。不知何故，我在 CompletableFuture.allOf 方法中得到 nullpointerException：这里可能有什么问题？谢谢.. List<CompletableFuture<String>> completableFutures = new ArrayList<>(); for(Classx list : request.getlist()) { switch (list.getCases()) { case 1: completableFutures.add(asyncProcess(list)); break; case 2: completableFutures.add(asyncProcess2(list)); break; } } CompletableFuture<Void> allFutures = CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[0])); @Async public CompletableFuture<String> asyncProcess(Classx list) { try{ //..some codes } catch(Exception e){ //..some codes } return CompletableFuture.completedFuture(x.getX()); } @Async public CompletableFuture<String> asyncProcess2(Classx list) { try{ //..some codes } catch(Exception e){ //..some codes } return CompletableFuture.completedFuture(x.getX()); } 错误信息是： java.lang.NullPointerException at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1306) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1305) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.andTree(CompletableFuture.java:1303) at java.util.concurrent.CompletableFuture.allOf(CompletableFuture.java:2225) 当我按如下方式更改代码时，它会引发相同的错误。 CompletableFuture allFutures = CompletableFuture.allOf(completableFutures.toArray(new CompletableFuture[completableFuture.size()])); 查看CompletableFutre.andTree的源代码，似乎当传入数组的元素为null时抛出此异常。在您的 return 函数之一中必须有一些额外的 asyncProcees 语句可以返回 null。

java asynchronous java-8 nullpointerexception completable-future

回答 1 投票 0

为什么 thenAccept 在循环中不起作用？

在使用 CompletableFutures 时，我发现了这些我无法理解的输出。我将分享两个在我看来应该表现相同的片段。但他们不是。所以

java completable-future

回答 1 投票 0

如何增强CompletableFuture Join性能

我在java项目中工作，我使用ResTemplate调用rest api，我使用CompletableFuture进行并行调用，这是我的代码：列表>

java spring completable-future

回答 1 投票 0

如何加快并行列表处理速度

我正在尝试解决一个问题：有一个字符串列表，每个字符串必须单独处理。每个字符串的处理时间大约为 40-50 ms，如果列表中有 200 个字符串，那是 ar...