Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
返回在响应的特定条件下首先执行的 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
如何在 Mockito 中模拟 CompletableFuture 的完成
我想模拟当某个代码被调用时CompletableFuture已成功完成 我有这门课 public class MyClassImplementRunner implements Runnable private final String p
Java
Mockito
CompletableFuture
作者使用 thenCompose 而不是 thenComposeAsync 的原因是否正确
这个问题和这个问题不一样Java8 thenCompose 和 thenComposeAsync 之间的区别 https stackoverflow com questions 46130969 difference between jav
Java
java8
CompletableFuture
定义API时我应该返回CompletableFuture还是Future?
在Java 8中 接口或抽象类定义返回的API更好吗 CompletableFuture而不是返回Future 考虑到转换很难看Future to CompletableFuture https stackoverflow com ques
Java
interface
java8
Future
CompletableFuture
返回一个 CompletableFuture 而不暴露执行器线程
我在库中公开了一个方法 该方法返回一个 CompletableFuture 该方法的计算发生在单线程执行器上 这是我的瓶颈 因此我不希望任何后续工作发生在同一线程上 如果我使用返回 supplyAsync 结果的简单方法 我会将我宝贵的线程
Java
concurrency
CompletableFuture
Apache Pulsar 异步消费者设置(未来可完成)
我正在尝试为 Apache Pulsar 设置异步使用者 但我的问题是仅收到 1 条消息 除非重新启动 Spring Boot 应用程序 否则不会收到其他消息 不幸的是 有关使用 CompletableFuture 和 Pulsar 的文档
Java
CompletableFuture
apachepulsar
CompletableFuture 循环中:如何收集所有响应并处理错误
我正在尝试调用rest apiPUT循环请求 每个调用都是一个CompletableFuture 每个 api 调用都会返回一个类型的对象RoomTypes RoomType 我想收集响应 成功和错误 响应 在不同的列表中 我该如何实现这一
Java
Multithreading
Asynchronous
java8
CompletableFuture
1
2
3
»