在Java 8中，可以显式完成的Future（设置其值和状态），并且可以包括在完成时触发的依赖函数和动作。
public List doSomething(List list) { ExecutorService executorService = Executors.newCachedThreadPool(); int size = list.size(); 列表...
Spring异步分离controller的线程让response在给出response之前不会等待
在放入项目之前使用@Async 在 spring boot 中尝试异步。 问题是控制器的响应。 如您所见，rest 模板响应时间的日志很短，但是
在放入项目之前使用@Async 在 spring boot 中尝试异步。 问题是控制器的响应。 如您所见，rest 模板响应时间的日志很短，但是
CompletableFuture 与 Kafka 的回调方法？
我们正在围绕 Kafka 构建一个小型包装器库。我们使用的是旧版本，其中没有 .whenComplete((response, throwable) -> {...});当调用 kafkaTemplate.send(...); 时。 相反我们的
我有以下代码片段： @Async("执行器") 公共 CompletableFuture> getSecondObject(List firstObject) {
更好的 CompletableFuture 方法 acceptEither 与 acceptEitherAsync 有什么区别？
例如- CompletableFuture.supplyAsync(stage1).acceptEither(stage2, 消费者); stage1 和 stage2 应该在上面的代码中并行运行，因为它使用的是 acceptEither 如果我换成
CompletableFuture.get() 在 JUnit 中抛出 java.util.concurrent.TimeoutException
我正在努力用 KafkaTemplate 和 CompletableFuture 为我的 kafka 生产者编写 JUnit 测试。对不调用 get() 的方法的类似测试工作正常。 这是我的kafka制作人课程（
CompletableFuture thenApply 在单独的线程中运行，而不是在调用者线程中运行？
当我执行 CompletableFuture 的 thenApply 方法时，此方法的执行发生在 ForkJoinPool 线程中，而不是调用者（主）线程中。为什么会这样？这个结果即使用叉子
在 java 中，我有一个可以返回结果或 null 的期货列表。 如何等待哪个先完成，如果它返回结果则忽略其余部分，但如果它返回 null 等待另一个 ...
在出现异常的情况下组合两个 future 时返回至少一个 Completable Future
CompletableFuture future1 = CompletableFuture.supplyAsync(() -> { 返回“你好”； }); CompletableFuture future1 = CompletableFuture.supplyAsync(() -&g...
CompletableFutures 不起作用的 Groovy 异步合并方法
我有这个 SheetMerger，它有这种异步合并 SheetModel 的方法。这些 SheetModels 本身就是从不同的 Sheets 中异步获取的结果，有些有 thousa...
如果 5 个线程中有一个线程抛出异常，如何在可完成的未来将线程分配给公共池
我有一个代码，我需要并行调用不同的服务，所以我使用了可完成的未来来并行调用它，但是如果 5 个线程中有 1 个线程抛出异常 我怎么...
为什么当模拟方法调用返回CompletableFuture对象时，JUnit不完成？
public class A{ @Autowired B b; public List(列表) method1(){ CompletableFuture > completableFuture = b.getCompletableFutureList(); / ...
我英语不好。我使用的是异步方法。选项1 公共CompletableFuture getDiscountPriceAsync(Integer price) { return CompletableFuture.supplyAsync(()-> ......
所以之前我考试的时候，有这个问题。我的问题是针对CompletableFuture.anyOf。当其中一个进程完成时，另一个进程是否会在另一个......完成后也完成。
与StreamObserver异步交互，即与Java 8以上的CompletableFutures交互是否安全？
我在看grpc.io的基本教程中的简单RPC例子。@Override public void getFeature(Point request, StreamObserver) responseObserver) { responseObserver.onNext(...)
在Java中有没有一种方法可以将一个文件以异步方式复制到另一个文件中？我想找到类似于C#中的Stream.CopyToAsync的方法。我想实现的是下载一个 ...
为什么Reactor的Mono.fromCompletionStage比普通的CompletableFuture慢？
我有一段简单的代码，在后台 "处理 "数据，每处理完第n个项目后，记录最后n个项目所花费的总时间： class BackgroundWorker implements AutoCloseable { private ...。
监视、调试和跟踪 CompletableFuture 任务。
我想在使用CompletableFuture时监控、跟踪和调试我的任务，例如下面的代码。CompletableFuture.supplyAsync(() -> 2) .thenApply(i -> i*2) ......。
Scala未来到Java Completable未来[封闭式]
1-有任何lib或建议我们从Scala未来到Java Completable未来？我有一个遗留系统，我需要适应一个Scala库，返回期货在其API。2 - ...