Я использую jsr166y ForkJoinPool для распределения вычислительных задач между потоками. Но я, очевидно, что-то делаю не так.
Мои задачи, кажется, работают безупречно, если я создаю ForkJoinPool с параллелизмом> 1 (по умолчанию Runtime.availableProcessors (); я работал с 2-8 потоками). Но если я создаю ForkJoinPool с параллелизмом = 1, я вижу тупики после непредсказуемого числа итераций.
Да - установка параллелизма = 1 - странная практика. В этом случае я профилирую параллельный алгоритм по мере увеличения числа потоков и хочу сравнить параллельную версию, запущенную с одним потоком, с базовой последовательной реализацией, чтобы точно определить издержки параллельной реализации .
Ниже приведен простой пример, который иллюстрирует проблему, которую я вижу. Задача - это фиктивная итерация по фиксированному массиву, рекурсивно разделенная на 16 подзадач.
При запуске с THREADS = 2 (или более) он надежно работает до завершения, но при запуске с THREADS = 1 он неизменно блокируется. После непредсказуемого числа итераций основной цикл зависает в ForkJoinPool.invoke (), ожидая task.join (), и рабочий поток завершается.
Я работаю с JDK 1.6.0_21 и 1.6.0_22 под Linux и использую версию jsr166y, загруженную несколько дней назад с веб-сайта Дуга Ли (http://gee.cs.oswego.edu/dl/concurrency-interest/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));
}
}
}
}