兩個線程之間的通信

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 
    } 
    } 
} 

其他線程就可以調用queue.put()將消息發送到線程A。

Answer 2

在一個簡單的情況下，你可以添加一些實例變量給線程A類，讓線程B設置它的值來表明線程A必須清除它的隊列。在更高級的情況下，您可以使用線程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 
    } 
}