两个线程之间的通信

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