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

在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()方法进行通信。生产者生产一个产品后，唤醒消费者线程；消费者消费一个产品后，等待生产者生产。这样就实现了线程间的同步和通信。

0 赞

0 踩