为何ForkJoinTask.join()阻塞线程而非按预期执行工作窃取？

你的代码无法全程保持并行的核心原因是任务拆分逻辑形成了串行依赖链，完全限制了ForkJoinPool的工作窃取机制发挥作用，具体拆解如下：

1. 任务执行的依赖链陷阱 #

每个work>1的任务执行流程是：

• fork出一个work-1的子任务
• 自己执行work=1的耗时任务（1秒）
• 调用s.join()等待子任务完成

这个逻辑会形成一条自上而下的依赖链：

• 初始任务（work=20）必须等它fork的work=19任务完成，才能结束
• work=19任务必须等它fork的work=18任务完成，才能结束
• ...以此类推，直到最底层的work=1任务完成

当线程执行某个任务时，完成自身1秒的工作后，就会卡在join()调用上，等待子任务结束。而子任务被其他线程窃取后，又会重复同样的流程，最终所有线程都会陷入等待状态，只有最末端的work=1任务在执行，整个流程退化为串行。

2. 工作窃取机制无法生效 #

ForkJoinPool的核心是工作窃取：空闲线程会从其他线程的任务队列末尾窃取任务执行。但你的代码中，所有fork出去的任务都存在一个前提：必须先完成自身的1秒工作，才能继续处理后续逻辑。当线程窃取到这类任务后，执行完1秒工作就会立刻进入join等待，没有多余的任务可以被其他线程窃取——整个任务池里的任务都处于“等待子任务”的阻塞状态，自然无法保持并行。

修正思路 #

要实现预期的并行，需要打破这种串行依赖链，让线程在等待子任务时能有其他可执行的任务。比如调整拆分逻辑：

protected void compute() {
    System.out.println(Thread.currentThread().getName() + " compute enter: " + this);
    if (work > 1) {
        // 拆分出所有单个工作任务
        List<Task> subtasks = new ArrayList<>();
        while (work > 0) {
            subtasks.add(new Task(1, taskNum++));
            work--;
        }
        // fork所有子任务
        subtasks.forEach(Task::fork);
        // 等待所有子任务完成
        subtasks.forEach(Task::join);
    } else {
        doWork();
    }
    System.out.println(Thread.currentThread().getName() + " compute exit: " + this);
}

或者更高效的方式：根据并行度设置拆分阈值，避免链式join：

protected void compute() {
    System.out.println(Thread.currentThread().getName() + " compute enter: " + this);
    if (work > 5) { // 匹配ForkJoinPool的并行度5
        var s = new Task(work - 5, taskNum + 1);
        s.fork();
        // 当前线程先处理5份工作
        for (int i = 0; i < 5; i++) {
            new Task(1, taskNum + i).compute();
        }
        s.join();
    } else {
        // 直接处理剩余所有工作
        for (int i = 0; i < work; i++) {
            doWork();
        }
    }
    System.out.println(Thread.currentThread().getName() + " compute exit: " + this);
}

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