Java: Wait/Notify для нескольких потоков

Question

У меня есть класс, который содержит набор ссылок на рабочие потоки, которые получают объекты через TCP (1 на каждого клиента).

Я пытаюсь сделать способ getMessage() в своем классе, который ждет, пока ни один из рабочих потоков не получит сообщение и не вернет его.

То, что я получил прямо сейчас социологическая-система:

public Object getMessage() { 
    while (true) { 
     for (Worker w : workers.values()) 
      if (w.msgNumber() != 0) 
       return w.getLastMsg(); 
     Thread.sleep(100); 
    } 
} 

Это работает, но я не думаю, что это очень масштабируемым.

Я знаю, что я могу сделать wait(timeout) на каждого работника, но проблема остается прежней.

Есть ли какой-нибудь механизм ожидания/уведомления, который ждет несколько потоков?

Answer 1

Вы можете посмотреть, используя блокирующую очередь для связи между потоками. Рабочий поток будет вставляться в очередь, а функция getMessage() вытаскивает сообщение из очереди.

Answer 2

Как о чем-то вроде:

try { 
     ServerSocket srv = new ServerSocket(port); 

     // Wait for connection from client. 
     while (true) { 
      System.out.println("Listening..."); 
      // Waits for connection 
      new Thread(new ServerWorkerThread(srv.accept())).start(); 

     } 
    } catch (IOException e) { 
     //handle 
    }