ForkJoinPool并行度= 1个死锁
我使用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/）下载的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 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));
}
}
}
}
看起来像ForkJoinPool中的一个错误。 所有我能在课堂上看到的东西都适合你的例子。 唯一的另一种可能性可能是你的任务之一抛出异常并且异常死亡（尽管这仍然应该被处理）。
链接地址: http://www.djcxy.com/p/6029.html