用于JavaCompletableFuture组合的线程？
我开始熟悉 JavaCompletableFuture组合，使用过 JavaScript 承诺。基本上，组合只是在指定的执行器上安排了链式命令。但是我不确定在执行组合时哪个线程正在运行。
假设我有两个执行者，executor1并且executor2；为简单起见，假设它们是单独的线程池。我安排了一个CompletableFuture（使用非常松散的描述）：
CompletableFuture<Foo> futureFoo = CompletableFuture.supplyAsync(this::getFoo, executor1);
然后，当做到这一点我转换Foo到Bar使用第二执行人：
CompletableFuture<Bar> futureBar .thenApplyAsync(this::fooToBar, executor2);
我知道getFoo()将从executor1线程池中的线程调用。我知道fooToBar()将从executor2线程池中的线程调用。
但是什么线程用于实际的组合，即在getFoo()完成和futureFoo()完成之后；但之前的fooToBar()命令被安排在executor2？换句话说，哪个线程实际运行代码以在第二个执行器上调度第二个命令？
调度是否作为executor1调用的同一线程的一部分执行getFoo()？如果是这样，这个可完成的未来组合是否等同于我fooToBar()在executor1任务的第一个命令中自己手动安排？
回答
这是故意未指定的。在实践中，当Async调用没有后缀的变体并表现出类似的行为时，它将由同样处理链式操作的相同代码处理。
所以当我们使用下面的测试代码
CompletableFuture.supplyAsync(() -> {
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
return "";
}, r -> new Thread(r, "A").start())
.thenAcceptAsync(s -> {}, r -> {
System.out.println("scheduled by " + Thread.currentThread());
new Thread(r, "B").start();
});
它可能会打印
scheduled by Thread[A,5,main]
因为完成前一阶段的线程用于调度依赖操作。
但是当我们使用
CompletableFuture<String> first = CompletableFuture.supplyAsync(() -> "",
r -> new Thread(r, "A").start());
LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(1));
first.thenAcceptAsync(s -> {}, r -> {
System.out.println("scheduled by " + Thread.currentThread());
new Thread(r, "B").start();
});
它可能会打印
scheduled by Thread[main,5,main]
到主线程调用时thenAcceptAsync，第一个 future 已经完成，主线程将自行调度操作。
但这并不是故事的结局。当我们使用
CompletableFuture<String> first = CompletableFuture.supplyAsync(() -> {
LockSupport.parkNanos(TimeUnit.MILLISECONDS.toNanos(5));
return "";
}, r -> new Thread(r, "A").start());
Set<String> s = ConcurrentHashMap.newKeySet();
Runnable submitter = () -> {
String n = Thread.currentThread().getName();
do {
for(int i = 0; i < 1000; i++)
first.thenAcceptAsync(x -> s.add(n+" "+Thread.currentThread().getName()),
Runnable::run);
} while(!first.isDone());
};
Thread b = new Thread(submitter, "B");
Thread c = new Thread(submitter, "C");
b.start();
c.start();
b.join();
c.join();
System.out.println(s);
它不仅可以打印组合B A和C A来自第一个场景B B和C C来自第二个场景。在我的机器上，它也可重现地打印组合，B C并C B指示thenAcceptAsync一个线程传递给的操作被另一个线程同时调用thenAcceptAsync不同的操作提交给执行程序。
这与评估此答案中描述的传递给thenApply（不带Async）的函数的线程的场景相匹配。正如开头所说，这正是我所期望的，因为这两件事很可能由相同的代码处理。但与评估传递给 的函数的线程不同，文档中甚至没有提到调用方法的线程。所以理论上，另一个实现可以使用一个完全不同的线程，既不调用未来的方法也不完成它。thenApplyexecuteExecutor