如何等待幾個對象

Question

我有一個線程必須等待來自不同線程的多個對象。

@Override 
public void run() { 
    while (true) { 
     for (BackgroundTask task : tasks) { 
      synchronized (task) { 
       if (task.isReady()) { 
        task.doTask(); 
       } 
      } 
     } 
    } 
} 

但它是一個愚蠢的使用CPU時間。 如何等待幾個對象？

Answer 1

請使用notifyaAll()而不是notify()，因爲notify會喚醒單線程，其中notifyAll（）會喚醒所有正在等待的線程。

Answer 2

您可以在Object上使用notify()和wait()。你如何使用它取決於你的程序的結構。

Answer 3

如果您可以修改BackgroundTask類，請在準備就緒時通知跑步者。爲你的runner類添加一個隊列，每當一個任務就緒時，它就可以將它自己添加到隊列中並通知它。

然後，runner類在隊列爲空時等待隊列，並在隊列沒有時從隊列中取出物品運行。

Answer 4

IMO CountDownLatch將是一個好方法。從的Javadoc引用：

class Driver2 { // ... 
    void main() throws InterruptedException { 
    CountDownLatch doneSignal = new CountDownLatch(N); 
    Executor e = ... 

    for (int i = 0; i < N; ++i) // create and start threads 
     e.execute(new WorkerRunnable(doneSignal, i)); 

    doneSignal.await();   // wait for all to finish 
    } 
} 

class WorkerRunnable implements Runnable { 
    private final CountDownLatch doneSignal; 
    private final int i; 
    WorkerRunnable(CountDownLatch doneSignal, int i) { 
     this.doneSignal = doneSignal; 
     this.i = i; 
    } 
    public void run() { 
     try { 
     doWork(i); 
     doneSignal.countDown(); 
     } catch (InterruptedException ex) {} // return; 
    } 

    void doWork() { ... } 
}