Java CompletableFuture与ForkJoinPool的关系及说明

CompletableFuture.supplyAsync(() -> {...});  // 使用ForkJoinPool.commonPool()
CompletableFuture.runAsync(() -> {...});     // 使用ForkJoinPool.commonPool()

ExecutorService customExecutor = Executors.newFixedThreadPool(10);
CompletableFuture.supplyAsync(() -> {...}, customExecutor);  // 使用自定义线程池

import java.util.concurrent.*;

public class CompletableFuturePoolExample {
    public static void main(String[] args) {
        // 默认使用ForkJoinPool.commonPool()
        CompletableFuture<Void> defaultPoolFuture = CompletableFuture.runAsync(() -> {
            System.out.println("Default pool - Thread: " + Thread.currentThread().getName());
        });
        
        // 使用自定义线程池
        ExecutorService customPool = Executors.newFixedThreadPool(2);
        CompletableFuture<Void> customPoolFuture = CompletableFuture.runAsync(() -> {
            System.out.println("Custom pool - Thread: " + Thread.currentThread().getName());
        }, customPool);
        
        // 等待任务完成
        CompletableFuture.allOf(defaultPoolFuture, customPoolFuture).join();
        customPool.shutdown();
    }
}

System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "8");