ForkJoinPool 并行度=1 死锁

Question

我正在使用 jsr166y ForkJoinPool 在线程之间分配计算任务。但我显然做错了什么。

如果我创建并行度 > 1 的 ForkJoinPool（默认为 Runtime.availableProcessors()；我一直在运行 2-8 个线程），我的任务似乎可以完美运行。但是，如果我创建并行度 = 1 的 ForkJoinPool，我会在不可预测的迭代次数后看到死锁。

是的 - 设置并行度 = 1 是一种奇怪的做法。在这种情况下，随着线程数的增加，我正在分析并行算法，并且我想将并行版本（以单个线程运行）与基线串行实现进行比较，以便准确确定并行实现的开销.

下面是一个简单的例子，说明了我看到的问题。 “任务”是对固定数组的虚拟迭代，递归地分为 16 个子任务。

如果以 THREADS = 2（或更多）运行，它会可靠地运行到完成，但如果以 THREADS = 1 运行，它总是会死锁。经过不可预知的迭代次数，主循环在 ForkJoinPool.invoke() 中挂起，等待 task.join()，工作线程退出。

我在 Linux 下使用 JDK 1.6.0_21 和 1.6.0_22 运行，并使用几天前从 Doug Lea 的网站 (http://gee.cs.oswego.edu/dl/concurrency-interest/index.html) 下载的 jsr166y 版本

对我所缺少的有什么建议吗？非常感谢。

package concurrent;

import jsr166y.ForkJoinPool;
import jsr166y.RecursiveAction;

public class TestFjDeadlock {

    private final static int[] intArray = new int[256 * 1024];
    private final static float[] floatArray = new float[256 * 1024];

    private final static int THREADS = 1;
    private final static int TASKS = 16;
    private final static int ITERATIONS = 10000;

    public static void main(String[] args) {

        // Initialize the array
        for (int i = 0; i < intArray.length; i++) {
            intArray[i] = i;
        }

        ForkJoinPool pool = new ForkJoinPool(THREADS);

        // Run through ITERATIONS loops, subdividing the iteration into TASKS F-J subtasks
        for (int i = 0; i < ITERATIONS; i++) {
            pool.invoke(new RecursiveIterate(0, intArray.length));
        }

        pool.shutdown();
    }

    private static class RecursiveIterate extends RecursiveAction {

        final int start;
        final int end;

        public RecursiveIterate(final int start, final int end) {
            this.start = start;
            this.end = end;
        }

        @Override
        protected void compute() {

            if ((end - start) <= (intArray.length / TASKS)) {
                // We've reached the subdivision limit - iterate over the arrays
                for (int i = start; i < end; i += 3) {
                    floatArray[i] += i + intArray[i];
                }

            } else {
                // Subdivide and start new tasks
                final int mid = (start + end) >>> 1;
                invokeAll(new RecursiveIterate(start, mid), new RecursiveIterate(mid, end));
            }
        }
    }
}

Answer 1

看起来像 ForkJoinPool 中的一个错误。我在该课程的用法中看到的所有内容都适合您的示例。唯一的另一种可能性可能是您的任务之一抛出异常并异常死亡（尽管仍应处理）。