Javaの "飢餓のない"実装

Question

ワーカースレッドの単純なミューテックスと条件変数を使用している間、私のプログラムはまれで散発的なスレッドスターベーションエラーを取得します。

以下は、私がやっていることの簡単な例です。 4つのワーカースレッドが "Producer"を呼び出し、prod.getTasks（）を呼び出すメインスレッドがあります。

このコードは「デッドロックフリー」ですが、エラーのため「明らかに飢餓状態」ではありません。

私はスレッド飢餓やクロック飛躍が検出された（家政婦デルタ=1m18s317ms137μs765ns）を取得エラーは次のとおりです。

A）プロデューサーのスレッドが長すぎるために待機状態に座っているので？ （私はスレッドが使用準備が整う前に任意の時間を待つことができると信じているので、そうは思わない。確かに1分より長い）。

B）待機中のワーカースレッドの1つが何回も渡されたためですか？

基本的に、この飢餓を無料にするのに役立つヒントを教えてください。

class Producer implements Runnable 
{ 
    private static ArrayList<Task> arrTasks = new ArrayList<Task>(); 

    void getTasks() 
    { 
     Task t = getTask(); // get Tasks from a producer specific recordset.  
     synchronized (arrTasks) 
     { 
      arrTasks.add(t); 
      arrTasks.notify(); 
     } 
    } 

    void run() 
    { 
     while (true) 
     { 
      Task t = null; 

      synchronized (arrTasks) 
      { 
       if (arrTasks.size() == 0) 
        arrTasks.wait(); 

       if (arrTasks.size() > 0) 
        t = arrTasks.remove(0); 
      } 

      if (t != null) 
       processTask(t); 

      if (mExit) 
       break; 
     } 
    } 
} 

Answer 1

プロデューサ/コンシューマパターンは常にいずれか、餓死うオーバーロードされ、又は無意味。これはパフォーマンスパターンではなく、抽象化に使用されます。

concurrent BlockingQueueを使用すると、すべて​​を削除できるので、コードをもっと簡単に作成できます。