温馨提示×

java wait()方法如何进行线程间通信

小樊
81
2024-12-06 03:08:55
栏目: 编程语言

在Java中,wait()方法是Object类的一个方法,主要用于线程间的通信。当一个线程调用某个对象的wait()方法时,该线程会释放该对象的锁并进入等待状态,直到其他线程调用同一个对象的notify()notifyAll()方法唤醒它。

以下是使用wait()方法进行线程间通信的基本步骤:

  1. 在需要同步的代码块或方法前,使用synchronized关键字锁定对象。这样可以确保在同一时间只有一个线程可以访问这个代码块或方法。
synchronized (lockObject) {
    // 需要同步的代码
}
  1. 在需要等待的线程中,调用对象的wait()方法。这将导致线程释放锁并进入等待状态。
lockObject.wait();
  1. 在需要唤醒等待线程的线程中,调用对象的notify()notifyAll()方法。notify()方法只唤醒一个等待线程,而notifyAll()方法会唤醒所有等待线程。
lockObject.notify(); // 或 lockObject.notifyAll();
  1. 当等待线程被唤醒后,它将尝试重新获取锁。如果成功获取到锁,它将退出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()方法进行通信。生产者生产一个产品后,唤醒消费者线程;消费者消费一个产品后,等待生产者生产。这样就实现了线程间的同步和通信。

0