2つのスレッド間の通信

Question

私はスレッドを持っています、Aにはリストがあります。リストにはいくつかのオブジェクトがあります。今私はスレッドAに何らかのメッセージを送ることができるメカニズムを設計したいと思う。

Thread Aはループして実行されます（待機したりスリープしません）。 その他のスレッドBは、スレッドAにメッセージを送信し、スレッドAはすべてのキューを空にします。

スレッド間でメッセージを送信するにはどうすればよいですか？

class A extends Thread { 
    List<Object> objs = something; //Init it 
    void run() { 
     while(true) { 
      //Body which works on objects. 
      //After receiving an external message, "A" should perform some action, for example, empty objects. 
     } 
    } 
} 

編集： このようにすることはできますか？

class A extends Thread { 
    List<Object> objs = something; //Init it 
    Boolean flag = false; 

    public void setFlag(boolean value) { 
     synchronized(flag) { 
      this.flag = value; 
     } 
    } 

    public void getFlag() { 
     synchronized(flag) { 
      return this.flag; 
     } 
    } 

    void run() { 
     while(true) { 
      //Body which works on objects. 
      //After receiving an external message, A should perform some action, for example, empty objects. 
      if (getFlag == true) 
       //Empty list 
     } 
    } 
} 

Answer 1

メッセージオブジェクトはBlockingQueueです。他のスレッドはメッセージをキューに入れます。 while(true)ループの一部として、スレッドAはpollになり、到着したメッセージはすべて処理されます。コードで

：

class A extends Thread{ 
List<Object> objs = something ;//init it 
BlockingQueue<Message> queue = new LinkedBlockingQueue<Message>(); 
void run(){ 
    while(true){ 
     Message msg; 
     while ((msg = queue.poll()) != null) { 
     // process msg 
     } 
     // do other stuff 
    } 
    } 
} 

他のスレッドは今Aスレッドにメッセージを送信するためにqueue.put()を呼び出すことができます。

Answer 2

単純なケースでは、インスタンス変数をスレッドAクラスに追加し、スレッドAがそのキューをクリアする必要があることを示す値をスレッドBに設定させることができます。より高度な場合、スレッドAとスレッドBの両方がアクセスできるメッセージキューを使用できます。 Bはメッセージをそこに置き、Aはそれを読んで行動するだろう。

すべての場合、変数またはキューへのアクセスは、複数のスレッドアクセスに対して適切に保護されている必要があります。

Answer 3

コード内の別の場所で呼び出すことができるクラス "A"にメソッドを追加することができます。アクセス可能な場所にクラス "A"のインスタンスへの参照を保持してください。

class A extends Thread{ 
List<Object> objs = something ;//init it 
void run(){ 
    while(true){ 
     //body which works on objs 
     //open receiving external message A should perform some action ie empty objs 
    } 
    } 
    void ChangeState() 
    { 
    //clear objs 
    } 
}