Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
CompletableFuture:whenCompleteAsync() 不允许我重新抛出异常
我是 CompletableFuture 世界的新手 我正在尝试做一些负面测试 以允许我故意抛出异常的方式 该异常将决定通过 失败 这是代码片段 protected CompletableFuture
Java
Asynchronous
Exception
CompletableFuture
CompletableFuture 的多个 thenAccept 块的执行顺序是什么
所以我有一个返回a的方法CompletableFuture 在返回之前 此方法添加一个块thenAccept这是在之后执行的CompletableFuture完成 此方法的调用者还添加了另一个块thenAccept 显然 这可以通过多个链式
Java
java8
CompletableFuture
递归取消 allOf CompletableFuture
如果我有 CompletableFuture
Java
java8
CompletableFuture
如何从 completableFuture 创建 Mono
我正在尝试包裹CompletableFuture反应堆内Mono输入以简化我的转换操作 总的来说 Project Reactor 更方便 我正在 AWS Lambda 函数中工作 并使用新的 AWS Java SDK 2 x 版本调用 AW
awslambda
awssdk
projectreactor
CompletableFuture
Spring @Cacheable 和 @Async 注解
我需要缓存一些异步计算的结果 具体来说 为了克服这个问题 我尝试使用 Spring 4 3 缓存和异步计算功能 作为示例 我们采用以下代码 Service class AsyncService Async Cacheable users C
Java
Spring
springcache
CompletableFuture
springasync
为什么 CompletableFuture 的 thenAccept() 不在主线程上运行
我在 CompletableFuture 的 SupplyAsync 中处理长时间运行的操作 并将结果放入 thenAccept 中 有时 thenAccept 在主线程上执行 但有时它在工作线程上运行 但我只想在主线程上运行 thenAc
Java
CompletableFuture
返回在响应的特定条件下首先执行的 future
我正在尝试使用 completablefutures 进行 3 个休息调用 并返回第一个与特定响应匹配的调用 下面是我为其编写的示例测试代码 减去其余调用 但这似乎不起作用 即使有等待时间 我总是看到 future1 被返回 这意味着 te
Java
Asynchronous
java8
Future
CompletableFuture
串流期货列表的最有效方式
我通过流式传输对象列表来调用异步客户端方法 该方法返回 Future 迭代调用后返回的 Future 列表的最佳方法是什么 以便处理先出现的 Future 注意 异步客户端仅返回 Future 而不返回 CompletableFuture
Java
concurrency
java8
Future
CompletableFuture
带有 CompletableFuture 的 MDC 记录器
我正在使用 MDC Logger 除了一种情况外 它对我来说非常适合 无论我们在代码中的何处使用 CompletableFuture 对于创建的线程 MDC 数据都不会传递到下一个线程 因此日志会失败 例如 在代码中我使用下面的代码片段来创
Java
logback
slf4j
CompletableFuture
MDC
Mono 与 CompletableFuture
CompletableFuture在单独的线程上执行任务 使用线程池 并提供回调函数 假设我有一个 API 调用CompletableFuture 这是 API 调用阻塞吗 线程会被阻塞直到它没有从 API 得到响应吗 我知道主线程 tom
Java
reactiveprogramming
projectreactor
CompletableFuture
如何执行 CompletableFuture 数组并组合其结果
我正在研究 Java 8CompletableFutures并阅读 并看到 我应该采用thenCompose代替thenApply 我已将我的代码转换为使用thenCompose但我有一种不正确的感觉 这是我的控制代码 final Comp
Java
java8
CompletableFuture
CompletableFuture 已完成,但有异常
CompletableFuture completedFuture https docs oracle com javase 9 docs api java util concurrent CompletableFuture html co
Java
Exception
CompletableFuture
spring hibernate异步任务问题未找到当前线程的会话
这是我保存数据的方法 工作正常 public Future
Java
Spring
Multithreading
Hibernate
CompletableFuture
如何调试CompletableStage死锁?
我最近遇到的最困难的调试问题是异步操作之间的死锁 例如 给定两个CompletionStage链 其中第一个链调用依赖于第二个链的完成的方法 第二个链调用依赖于第一个链的完成的方法 这在现实生活中并不那么明显 因为依赖关系往往是隐藏的 有时
Java
debugging
Asynchronous
CompletableFuture
为什么我的 CompletableFuture 代码可以在 Java 8 中运行,但不能在 Java 11 中运行?
为什么这段代码在 Java 8 和 Java 11 中的行为不同 private static String test2 CompletableFuture runAsync gt IntStream rangeClosed 1 20 fo
Java
Multithreading
Asynchronous
JAVA11
CompletableFuture
为什么主线程不等待其他异步进程(线程)完成。 allOff 无法正常工作
我在 for 循环内调用一个异步方法 并将其 future 添加到列表中 我不确定为什么 allOff 不等待完成所有 future 并返回部分结果 看看我的代码 我有一个被重写的方法 Overide Async CompletableFu
Java
Multithreading
Asynchronous
CompletableFuture
从 CompletableFuture.allof() 获取单独的结果
我有一个类 它使用 CompletableFutures 向两个依赖服务发出并发请求 我的代码如下所示 Builder Slf4j public class TestClass NonNull private final ExecutorS
Java
concurrency
CompletableFuture
如果在 runAsync 调用之后链接,那么 thenRunAsync(与 thenRun 相对)是否有任何区别?
在下面的代码中 调用有什么区别吗thenRunAsync 我应该打电话吗thenRun反而 CompletableFuture runAsync this doWork executorService thenRunAsync this h
Java
java8
CompletableFuture
当任何给定的 CompletableFutures 完成且结果与某个谓词匹配时,如何创建一个完成的 future?
我有一个清单CompletableFuture
Java
Asynchronous
CompletableFuture
如何使用 CompletableFuture 并行运行多个服务调用?
我正在向用户返回以下响应 class FinalResponseDTO List
Java
Multithreading
Asynchronous
CompletableFuture
1
2
3
»