Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何在 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
从 CompletableFuture 捕获未捕获的异常
我正在尝试捕获像这样的期货中未捕获的异常CompletableFuture runAsync gt throw new RuntimeException 我的目标是当开发人员忘记处理这些异常时 让它们不再沉默 Calling get or
Java
ThreadPool
javautilconcurrent
CompletableFuture
CompletableFutures 并根据内部值进行过滤
我现在有点困惑 所以我有一个应该返回的方法CompletableFuture
Java
Lambda
filter
java8
CompletableFuture
Java 8 多线程:如何实现并行性以及单个线程的超时?
我想要实现的目标摘要 我想并行执行 N 个任务 这样任何单个任务的运行时间都不应超过两秒 我们可以将此类任务标记为失败 作为输出 我想返回成功任务的输出和失败任务的状态为失败 此外 一项任务的超时不应导致电路中断 即其他任务的执行不应停止
Java
java8
ExecutorService
CompletableFuture
完整的未来 | thenApplyAsync 与 thenCompose 及其用例[重复]
这个问题在这里已经有答案了 我试图理解 CompletableFuture 并遇到了两种方法 thenApplyAsync 和 thenCompose 我试图理解这两者之间的区别 CompletableFuture
Java
java8
CompletableFuture
ForkJoinTask 与 CompletableFuture
在 Java 8 中 有两种启动异步计算的方法 CompletableFuture and ForkJoinTask 它们看起来都非常相似 内部类CompletableFuture甚至延长ForkJoinTask 有理由使用其中一种而不是另
Java
Future
ForkJoin
forkjoinpool
CompletableFuture
java CompletableFuture 相当于 scala Future 的救援和句柄是什么
我看到CompletableFuture有一个方法handle与 scala 相同Future s handle基本上将成功和异常全部转换为成功map and flatMap上游 或thenApply and thenCompose在Jav
Java
java8
CompletableFuture
Java - CompletableFutures - 如果出现异常,我如何取消所有期货
我有一个方法 包括在下面 来返回列表的值CompletableFutures 该方法应该 能够在给定时间后超时 如果有超过n个例外 能够取消所有期货 第一点效果很好 但在超过超时限制后确实失败了 我还需要打电话exectuorService
Java
Multithreading
CompletableFuture
如何取消Java 8的完整未来?
我正在玩 Java 8 completable futures 我有以下代码 CountDownLatch waitLatch new CountDownLatch 1 CompletableFuture
Java
Multithreading
java8
CompletableFuture
了解 CompletableFuture::runAsync
我刚刚读过文档 https docs oracle com javase 8 docs api java util concurrent CompletableFuture html runAsync java lang Runnable
Java
Multithreading
java8
CompletableFuture
Thread 与 CompletableFuture
与使用 CompletableFuture 相比 直接将代码传递给线程有什么优势 Thread thread new Thread gt do something thread start VS CompletableFuture
Java
Multithreading
java8
CompletableFuture
我如何在完整的未来测试异常?
我一直在将一些代码转换为异步代码 原来的单元测试使用了注解 Test expected MyExcpetion class 但我认为这不会起作用 因为我想要断言的异常被包装在java util concurrent ExcutionExce
Java
JUnit
java8
Junit4
CompletableFuture
Kotlin 协程 future 等待超时(不可取消)
鉴于我们有一个CompletableFuture f 在 kotlin 可挂起范围内我们可以调用f await 我们将暂停直到完成 我在使用签名实现类似功能时遇到问题f await t 必须暂停最大t毫秒或如果 future 在该持续时间内
Java
kotlin
kotlincoroutines
Coroutine
CompletableFuture
如何在最后访问多个 Completablefuture Stage 变量
我尝试在 completablefuture 管道的末尾使用多个不同的变量 很难解释 这是我的例子 private void test lib getHumanFromDatabase thenApplyAsync human gt ret
Java
Lambda
CompletableFuture
如何从异步 Http 客户端请求获取 CompletableFuture
?
On 异步 Http 客户端文档 https github com AsyncHttpClient async http client我看到如何获得Future
Asynchronous
java8
asynchttpclient
CompletableFuture
«
1
2
3
»