Giao tiếp giữa hai chủ đề

Question

Tôi có một chuỗi, A có danh sách. Danh sách chứa một số đối tượng. Bây giờ tôi muốn thiết kế một mechanisim mà tôi có thể gửi một số tin nhắn đến chủ đề A.

Thread A chạy trong vòng lặp (không chờ hoặc ngủ). Một số chủ đề khác, B, gửi một số tin nhắn đến chủ đề A và luồng A làm trống tất cả các hàng đợi của nó.

Làm cách nào để gửi thư giữa các chuỗi?

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

EDIT: Tôi có thể làm như thế này không?

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

Bạn có thể có BlockingQueue đối tượng tin nhắn. Các chủ đề khác sẽ đặt các thông điệp lên hàng đợi. Là một phần của vòng lặp while(true), luồng A sẽ poll xếp hàng và xử lý bất kỳ thư nào đã đến.

Trong mã:

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

đề khác bây giờ có thể gọi queue.put() để gửi tin nhắn cho chủ đề A.

Answer 2

Trong trường hợp đơn giản, bạn có thể thêm một số biến mẫu vào chuỗi A và có chuỗi B đặt giá trị của nó để cho biết luồng A phải xóa hàng đợi của nó. Trong trường hợp nâng cao hơn, bạn có thể sử dụng một số hàng đợi thông điệp mà cả hai luồng A và B đều có thể truy cập. B sẽ đặt một tin nhắn ở đó và A sẽ đọc và hành động trên đó.

Trong mọi trường hợp, quyền truy cập vào biến hoặc hàng đợi phải được bảo vệ đúng cách để truy cập nhiều chủ đề.

Answer 3

Bạn sẽ có thể thêm phương thức vào lớp "A" có thể được gọi ở nơi khác trong mã của bạn. Chỉ cần giữ tham chiếu đến ví dụ của bạn về lớp "A" ở một nơi dễ tiếp cận.

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