wait()
方法是Java中的一个同步机制,用于让当前线程等待,直到其他线程调用同一个对象的notify()
或notifyAll()
方法。在使用wait()
方法时,需要遵循以下步骤:
-
确保线程间通信:
wait()
方法通常在多线程环境下使用,确保线程间正确通信是非常重要的。这通常涉及到共享数据(如变量、对象等)的访问和修改。 -
在同步代码块或方法中使用
wait()
:为了确保线程安全,需要在同步代码块或方法中使用wait()
。这可以通过在方法声明中添加synchronized
关键字来实现。 -
调用
wait()
前检查条件:在调用wait()
之前,需要检查线程等待的条件是否满足。如果不满足,线程将立即退出wait()
状态。 -
使用
notify()
或notifyAll()
唤醒线程:当其他线程修改了共享数据并满足等待线程的条件时,需要调用notify()
或notifyAll()
方法唤醒等待的线程。notify()
只唤醒一个等待线程,而notifyAll()
会唤醒所有等待线程。
下面是一个简单的示例:
public class Example { private int counter = 0; public synchronized void increment() { counter++; if (counter < 10) { System.out.println(Thread.currentThread().getName() + " incremented counter to " + counter); notify(); // 唤醒等待的线程 } else { System.out.println(Thread.currentThread().getName() + " reached 10, notifying all threads."); notifyAll(); // 唤醒所有等待的线程 } } public synchronized void waitUntilCounterLessThan10() throws InterruptedException { while (counter >= 10) { System.out.println(Thread.currentThread().getName() + " waiting for counter to be less than 10."); wait(); // 等待被唤醒 } System.out.println(Thread.currentThread().getName() + " counter is now less than 10."); } public static void main(String[] args) { Example example = new Example(); Thread t1 = new Thread(() -> { try { example.waitUntilCounterLessThan10(); } catch (InterruptedException e) { e.printStackTrace(); } }, "Thread-1"); Thread t2 = new Thread(() -> { try { example.increment(); } catch (InterruptedException e) { e.printStackTrace(); } }, "Thread-2"); t1.start(); t2.start(); } }
在这个示例中,我们有一个名为Example
的类,其中包含两个同步方法:increment()
和waitUntilCounterLessThan10()
。increment()
方法在计数器达到10时调用notifyAll()
唤醒所有等待的线程,而在计数器小于10时调用notify()
唤醒一个等待的线程。waitUntilCounterLessThan10()
方法使用wait()
等待计数器小于10。在main()
方法中,我们创建了两个线程,一个等待计数器小于10,另一个递增计数器。