在Java中,wait()
方法是Object
类的一个方法,主要用于线程间的通信。当一个线程调用某个对象的wait()
方法时,该线程会释放该对象的锁并进入等待状态,直到其他线程调用同一个对象的notify()
或notifyAll()
方法唤醒它。
以下是使用wait()
方法进行线程间通信的基本步骤:
- 在需要同步的代码块或方法前,使用
synchronized
关键字锁定对象。这样可以确保在同一时间只有一个线程可以访问这个代码块或方法。
synchronized (lockObject) { // 需要同步的代码 }
- 在需要等待的线程中,调用对象的
wait()
方法。这将导致线程释放锁并进入等待状态。
lockObject.wait();
- 在需要唤醒等待线程的线程中,调用对象的
notify()
或notifyAll()
方法。notify()
方法只唤醒一个等待线程,而notifyAll()
方法会唤醒所有等待线程。
lockObject.notify(); // 或 lockObject.notifyAll();
- 当等待线程被唤醒后,它将尝试重新获取锁。如果成功获取到锁,它将退出
wait()
方法并继续执行后续代码。
下面是一个简单的示例:
public class WaitNotifyExample { private static final Object lock = new Object(); private static int count = 0; public static void main(String[] args) { Thread producer = new Thread(new Producer()); Thread consumer = new Thread(new Consumer()); producer.start(); consumer.start(); } } class Producer implements Runnable { @Override public void run() { synchronized (WaitNotifyExample.lock) { System.out.println("生产者生产了一个产品,计数器加1: " + ++WaitNotifyExample.count); WaitNotifyExample.lock.notify(); // 唤醒消费者线程 } } } class Consumer implements Runnable { @Override public void run() { synchronized (WaitNotifyExample.lock) { try { System.out.println("消费者消费了一个产品,等待生产者生产: " + WaitNotifyExample.count); WaitNotifyExample.lock.wait(); // 等待生产者生产 } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("消费者消费了一个产品,计数器减1: " + --WaitNotifyExample.count); } } }
在这个示例中,生产者和消费者线程通过wait()
和notify()
方法进行通信。生产者生产一个产品后,唤醒消费者线程;消费者消费一个产品后,等待生产者生产。这样就实现了线程间的同步和通信。