Java中如何让CompletableFuture非阻塞任务优先执行（线程池受限）

我定义了一个包含2个线程的线程池：

Executor executor = Executors.newFixedThreadPool(2);

现有三个任务，其中两个为阻塞任务，一个为非阻塞任务：

CompletableFuture<Integer> blocking1 = CompletableFuture.supplyAsync(callableTask1, executor);
CompletableFuture<Integer> blocking2 = CompletableFuture.supplyAsync(callableTask2, executor);

CompletableFuture<Void> nonBlocking = CompletableFuture.runAsync(() -> {
    System.out.println("nonBlocking task's thread:  " + Thread.currentThread());
    System.out.println("Non Blocking task");
});

callableTask1和callableTask2均为阻塞任务，会使线程进入等待状态。当前非阻塞任务需等待阻塞任务释放线程才能执行，我希望非阻塞任务无需等待任何任务完成即可立即执行，输出顺序为："Non Blocking task" 优先输出，随后输出"callable Task1"或"callable Task2"。

核心问题是非阻塞任务默认使用的ForkJoinPool.commonPool()可能存在资源竞争，导致需要等待。要让非阻塞任务立即执行，最稳妥的方式是给它分配独立的线程资源：

方法1：为非阻塞任务单独创建线程池 #

给非阻塞任务指定专属的单线程池，确保它能立即获得线程执行：

// 为非阻塞任务创建独立线程池
Executor nonBlockingExecutor = Executors.newSingleThreadExecutor();

CompletableFuture<Void> nonBlocking = CompletableFuture.runAsync(() -> {
    System.out.println("nonBlocking task's thread:  " + Thread.currentThread());
    System.out.println("Non Blocking task");
}, nonBlockingExecutor);

原理说明 #

• 自定义的2线程池被两个阻塞任务完全占用，线程处于等待状态无法释放；
• 非阻塞任务使用独立线程池后，无需依赖自定义线程池的空闲资源，会立即启动执行，优先输出目标内容；
• 阻塞任务会在各自线程的等待结束后，再输出对应的内容。

注意事项 #

如果不想额外创建线程池，也可以检查ForkJoinPool.commonPool()的可用线程数（默认是CPU核心数-1），若当前环境下commonPool有空闲线程，非阻塞任务也能立即执行，但这种方式依赖全局线程池状态，稳定性不如专属线程池方案。

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