ForkJoinPool parallelism = 1死锁
我正在使用jsr166y ForkJoinPool在线程之间分配计算任务。 但我显然必须做错事。
如果我创建并行度> 1的ForkJoinPool（默认为Runtime.availableProcessors（）;我一直在运行2-8个线程），我的任务似乎完美无缺。 但是如果我创建具有parallelism = 1的ForkJoinPool，我会在不可预测的迭代次数之后看到死锁。
是的 – 设置parallelism = 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/）下载的jsr166y版本index.html ）
对我遗失的任何建议？ 提前谢谢了。
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 FJ 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 >> 1; invokeAll(new RecursiveIterate(start, mid), new RecursiveIterate(mid, end)); } } } } 看起来像ForkJoinPool中的一个错误。 我在课堂用法中可以看到的一切都符合你的榜样。 唯一的其他可能性可能是你的任务之一抛出exception并且exception死亡（尽管仍然应该处理）。