Komunikacja między dwoma wątkami

Question

Mam wątek, A, który ma listę. Lista zawiera niektóre obiekty. Teraz chcę zaprojektować mechanisim, za pomocą którego mogę wysłać wiadomość do wątku A.

działa w pętli (nie czeka ani nie zasypia). Inny wątek, B, wysyła wiadomość do wątku A, a wątek A opróżnia wszystkie jego kolejki.

Jak mogę wysyłać wiadomości między wątkami?

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

EDYCJA: Czy mogę zrobić to w ten sposób?

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

Możesz mieć BlockingQueue obiektów wiadomości. Inne wątki umieszczałyby wiadomości w kolejce. W ramach pętli while(true), wątek A będzie poll kolejki i przetwarzać wszystkie wiadomości, które przybyły.

W kodzie:

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

Inne wątki mogą teraz zadzwonić queue.put() wysyłać wiadomości do wątku A.

Answer 2

W uproszczonym przypadku można dodać zmienną instancji do klasy wątku A i mieć wątek B ustawić jego wartość, aby wskazać, że wątek A musi wyczyścić swoje kolejki. W bardziej zaawansowanym przypadku możesz użyć kolejki komunikatów, do których mają dostęp oba wątki A i B. B umieściłby tam wiadomość, a A odczytałby i działał na jej podstawie.

We wszystkich przypadkach dostęp do zmiennej lub kolejki musi być odpowiednio chroniony, aby uzyskać dostęp do wielu wątków.

Answer 3

Powinieneś być w stanie dodać metodę do klasy "A", którą można wywołać w innym miejscu kodu. Po prostu zachowaj odwołanie do swojego wystąpienia klasy "A" w dostępnym miejscu.

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