ForkJoinPool並列処理= 1デッドロック

Question

私はスレッド間で計算タスクを配布するためにjsr166y ForkJoinPoolを使用しています。しかし、私は間違ったことをしているに違いない。

並列処理> 1（デフォルトはRuntime.availableProcessors（）;私は2〜8スレッドで実行しています）のForkJoinPoolを作成すると、私のタスクは完璧に機能しているようです。しかし、並列性= 1のForkJoinPoolを作成すると、予測できない繰り返し回数の後にデッドロックが発生します。

はい - parallelism = 1を設定するのは奇妙な方法です。この場合、スレッド数が増えるにつれて並列アルゴリズムをプロファイリングしています。並列実装のオーバーヘッドを正確に把握するために、並列バージョンを比較して、単一のスレッドで実行し、ベースラインのシリアル実装にしたい。

以下は、私が見ている問題を示す簡単な例です。 'タスク'は、固定配列上のダミー反復であり、再帰的に16個のサブタスクに分割されます。

THREADS = 2（またはそれ以上）で実行すると、確実に完了まで実行されますが、THREADS = 1で実行すると常にデッドロックになります。予期せぬ数の反復の後、メインループはForkJoinPool.invoke（）でハングし、task.join（）を待機し、ワーカースレッドは終了します。

私はLinuxでJDK 1.6.0_21および1.6.0_22で実行している、と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)); 
      } 
     } 
    } 
} 

Answer 1

は、ForkJoinPoolのバグのようです。クラスの使用法でわかるすべてがあなたの例に合っています。他の唯一の可能性は、例外を投げて異常に死んでいるタスクの1つかもしれません。