同期とセマフォ

Question

私はマップを通してループしていますが、私はいくつかのスレッドを持っています。 マップのキューにはアクションが含まれています。私の目標は、すべてのスレッドに実行するアクションを与えることです.2つのスレッド（またはそれ以上）は1つのキューから2つのタスク（またはそれ以上）を実行できません。 すべてのスレッドがキューを検索し、キューにアクションがあるかどうかを確認します（はいの場合）。アクションを実行する別のキューを検索しない場合は、キューの1つを実行します。 注：キューの数は、別のスレッドが実行するアクションを探している場合はつもりであるということです私は「のMap.Entry」

 public void run() { 

      while (true) { 
       Action<?> act; 
       for (Map.Entry entry :ActionMap.entrySet()) { 
        Synchronized(entry) 
        { 
         act = ((Queue<Action>)entry.getValue()).poll(); 
         if (act == null) 
         break; 
        } 
       } 

      } 
      } 

問題で同期しようとした 電子 スレッドの数よりも大きくすることができます最初のスレッドがタスクを完了したり、待っているのを待っていて、それが私が望んでいないものであることを同期したLine And Waitに詰め込まれている。 私はいくつかのスレッドが別のスレッドがそれをスキップして

はので、私は周りに掘っ検索を続ける上で作業しているキューに到達した場合は、キューを検索するためのスレッドのすべてをしたいとセマフォたので、私はこの

Semaphore Gate = new Semaphore(1); 



     public void run() { 

      while (true) { 
       Action<?> act; 
       for (Map.Entry entry :ActionMap.entrySet()) { 
        if(Gate.tryAcquire()); 
        { 
         act = ((Queue<Action>)entry.getValue()).poll(); 
         if (act == null){ 
        Gate.Release(); 
        break; 

         } 
         else { 
         act.handle(); 
         Gate.Release(); 
        } 
        } 
       } 

      } 
      } 

に達しました

はGate.aquireは（）すべてのエントリが それが2つのdiffirentエントリおよび2つの異なるスレッドが1つだけのスレッドがゲートにアクセスし、アクション

を実行できることを意味しますので、最終的にはいずれかの用量つもりロックしているであることをこれで問題を置きます私を助けることができるデザインパターン？ ありがとうございました...

Answer 1

これにはjava.util.concurrentタイプのマップを使用できます。スレッドセーフなので、Syncronizeは必要ありません。

同期化：リソース（同期化されている）を複数のスレッドで同時に変更することはできません。 Collections.synchronizedMap（Map）によって返されるMAPは同期マップであり、一度に1つのスレッドで変更できますが、コンカレントコレクションでは、要件に基づいて、複数のスレッドが所定の時間にコレクションの異なる部分にアクセスできます。たとえばConcurentHashMapのオーバーロードされたコンストラクタがあります。ConcurntHashMapは入力concurrencyLevelをコレクションに同時にアクセスできるスレッド数として受け取ります。