我正在使用 jsr166y ForkJoinPool 在线程之间分配计算任务。但我显然一定做错了什么。
如果我创建并行度 > 1 的 ForkJoinPool(默认为 Runtime.availableProcessors();我一直在使用 2-8 个线程),我的任务似乎可以完美运行。但是,如果我创建并行度 = 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/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));
}
}
}
}
最佳答案
看起来像是 ForkJoinPool 中的错误。我在该类(class)的用法中看到的所有内容都适合您的示例。唯一的另一种可能性可能是您的任务之一抛出异常并异常终止(尽管仍应处理)。
关于java - ForkJoinPool 并行度=1 死锁,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5493399/