使用CompletableFuture时：为每个类单独用Executor还是共享？

这个问题没有绝对答案，得根据你的任务特性和需求来选：

优先选共享Executor的情况 #

• 类A和B的异步任务资源消耗模式差不多：比如都是调用外部接口的IO密集型任务，或者都是轻量计算任务
• 你想统一管控线程资源，避免创建太多线程池导致系统内存、CPU被过度占用
• 两类任务之间不需要隔离，一个类的任务出问题（比如临时阻塞）不会影响另一个类的任务执行

这种场景下，在外部创建一个Executor（比如用ThreadPoolExecutor自定义参数），然后注入给A和B就行，示例代码：

// 外部定义共享线程池
Executor sharedThreadPool = new ThreadPoolExecutor(
    4,    // 核心线程数
    8,    // 最大线程数
    60L, TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(50)
);

// 类A通过构造器注入共享线程池
public class A {
    private final Executor executor;

    public A(Executor executor) {
        this.executor = executor;
    }

    public CompletableFuture<String> methodA() {
        return CompletableFuture.supplyAsync(() -> {
            // 业务逻辑
            return "123";
        }, executor);
    }
}

// 类B同样注入共享线程池
public class B {
    private final Executor executor;

    public B(Executor executor) {
        this.executor = executor;
    }

    public CompletableFuture<String> methodB() {
        return CompletableFuture.supplyAsync(() -> {
            // 业务逻辑
            return "ABC";
        }, executor);
    }
}

适合用独立Executor的情况 #

• 类A和B的任务资源特性差异很大：比如A是CPU密集型的计算任务（需要少线程避免上下文切换），B是IO密集型的网络请求任务（需要多线程提高吞吐量）
• 需要任务隔离：比如A的任务可能会出现长时间阻塞，不想让它占满线程池影响B的任务执行
• 要给不同类的任务设置不同的线程池规则：比如不同的核心线程数、队列大小、拒绝策略

这种场景下给每个类单独创建专属Executor，示例代码：

public class A {
    // 类A专属CPU密集型线程池
    private static final Executor A_EXECUTOR = new ThreadPoolExecutor(
        Runtime.getRuntime().availableProcessors(),
        Runtime.getRuntime().availableProcessors(),
        60L, TimeUnit.SECONDS,
        new SynchronousQueue<>()
    );

    public CompletableFuture<String> methodA() {
        return CompletableFuture.supplyAsync(() -> {
            // 业务逻辑
            return "123";
        }, A_EXECUTOR);
    }
}

public class B {
    // 类B专属IO密集型线程池
    private static final Executor B_EXECUTOR = new ThreadPoolExecutor(
        10,
        20,
        60L, TimeUnit.SECONDS,
        new LinkedBlockingQueue<>(100)
    );

    public CompletableFuture<String> methodB() {
        return CompletableFuture.supplyAsync(() -> {
            // 业务逻辑
            return "ABC";
        }, B_EXECUTOR);
    }
}

总结 #

• 任务特性相近、无隔离需求？选共享Executor，管理起来更省心，还能避免资源浪费
• 任务差异大、需要隔离或单独配置？选独立Executor，避免任务之间互相干扰

内容的提问来源于stack exchange，提问作者Maicol