在Java中等待事件 - 它有多困難？

Question

我有一個線程不時更新它的狀態，我想要第二個線程能夠等待第一個線程完成。事情是這樣的：

Thread 1: 
    while(true) { 
     ...do something... 
     foo.notifyAll() 
     ...wait for some condition that might never happen... 
     ... 
    } 

Thread 2: 
    ... 
    foo.wait(); 
    ... 

現在，這看起來不錯，所有除非線程1的notifyAll的（）之前線程2的wait（），運行在這種情況下，線程2個等待直到線程1通知再次（可能永遠不會發生） 。

我可能的解決方案：

一）我可以使用的CountDownLatch或未來，但兩者有本質上它們只運行一次的問題。也就是說，在線程1的while循環中，我需要創建一個新的foo來等待每次，並且線程2需要詢問哪個foo要等待。我對簡單地寫

while(true) { 
    foo = new FutureTask(); 
    ... 
    foo.set(...); 
    ...wait for a condition that might never be set... 
    ... 
} 

一種不好的感覺，因爲我擔心，在富=新FutureTask（），當有人等着老FOO（對於「某些原因」，設置不叫會發生什麼，如異常處理中的錯誤）？

b）或我可以用一個信號：

class Event { 
    Semaphore sem; 
    Event() { sem = new Semaphore(1); sem . } 
    void signal() { sem.release(); } 
    void reset() { sem.acquire(1); } 
    void wait() { if (sem.tryAcquire(1)) { sem.release(); } } 
} 

但我擔心，有一些競爭條件，如果將多個線程wait（）就爲它而另外一個信號（）S和復位（ ）秒。

問：

有什麼類似於Windows事件行爲的Java API嗎？或者，如果你鄙視Windows，像golang的WaitGroup（即允許countUp（））的CountDownLatch）？什麼？

如何手動做到這一點：

線程2不能簡單地等待，因爲虛假喚醒，並在Java中沒有辦法知道爲什麼的Object.wait（）返回。所以我需要一個條件變量來存儲事件是否有信號。線程2：

synchronized(foo) { 
    while(!condition) { 
     foo.wait(); 
    } 
} 

而線程1當然在同步塊中設置條件爲真。感謝週末的提示！

是否有一個包裝該行爲的現有類？

還是我需要複製和粘貼代碼嗎？

Answer 1

標準做法是在執行notifyAll時更改某些狀態並在執行wait（）時檢查某些狀態。

例如

boolean ready = false; 

// thread 1 
synchronized(lock) { 
    ready = true; 
    lock.notifyAll(); 
} 


// thread 2 
synchronized(lock) { 
    while(!ready) 
     lock.wait(); 
} 

使用這種方法，線程1或線程2是否首先獲取鎖並不重要。

如果您使用通知或等待而不設置值或檢查值，某些編碼分析工具會給您一個警告。

Answer 2

最簡單的方法是隻是說

firstThread.join();

這將阻止，直到第一個線程終止。

但是你可以使用wait/notify來實現。不幸的是，你沒有發佈你的真實代碼片段，但我想如果等待不會退出，當你打電話通知它發生，因爲你沒有把這兩個​​塊。請注意，​​塊的「參數」對於等待/通知對必須相同。

Answer 3

您可以使用wait（）超時，在這種情況下，您不會冒着永遠等待的風險。還要注意，即使根本沒有notify（），wait（）也可能返回，因此，您需要在等待循環中包裝等待。這是用Java等待的標準方式。

synchronized(syncObject) { 
    while(condition.isTrue()) { 
     syncObject.wait(WAIT_TIMEOUT); 
    } 
} 

（在你的線程2）

編輯：感動外循環同步。

Answer 4

我會在兩個線程之間使用BlockingQueue。使用wait和notify是如此5分鐘前;）

enum Event { 
    Event, 
    Stop; 
} 

BlockingQueue<Event> queue = new LinkedBlockingQueue<Event>(); 

// Thread 1 
try { 
    while(true) { 
    ...do something... 
    queue.put(Event.Event); 
    ...wait for some condition that might never happen... 
    ... 
    } 
} finally { 
    // Tell other thread we've finished. 
    queue.put(Event.Stop}; 
} 

// Thread 2 
... 
switch (queue.take()) { 
    case Event: 
     ... 
     break; 

    default: 
     ... 
     break; 
}