在哪个线程上执行在new CompletableFuture（）上注册的回调？[副本]

Question

我是完全期货的新手，并试图了解在使用构造函数（new CompletableFuture（））构造的CompletableFuture上注册的回调在哪个线程上

例如：

CompletableFuture<String> future =
        CompletableFuture.supplyAsync(() -> {
            //...
        }, pool);
CompletableFuture<Integer> intFuture =
    future.thenApply(s -> s.length());

thenApply（）中的转换已注册，并将在任务完成后立即在与任务相同的线程中执行。

CompletableFuture<String> future = new CompletableFuture();
CompletableFuture<Integer> intFuture =
    future.thenApply(s -> s.length());
future.complete("hello");

thenApply（）中的转换被注册，任务完成后，将在哪个线程上使用future执行。完成（“你好”）？它是在主线程上执行还是在ForkJoinPool.commonPool（）上执行？

Answer 1

只有异步方法由新线程执行，因此在您的情况下，应用由主线程执行

所有没有显式执行器参数的异步方法都使用ForkJoinPool执行。commonPool（）（除非它不支持至少两个并行级别，在这种情况下，将创建一个新线程来运行每个任务）。

public class TestMain {

public static void main(String[] args) {

    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
        System.out.println(Thread.currentThread().getName());
        return "hello";
    });
    CompletableFuture<Integer> intFuture = future.thenApply(s -> {
        System.out.println(Thread.currentThread().getName());
        return s.length();
    });

    CompletableFuture<Integer> intFuture2 = future.thenApply(s -> {
        System.out.println(Thread.currentThread().getName());
        return s.length();
        });
       future.complete("hello");

     }

 }

输出

ForkJoinPool.commonPool-worker-1
main
main