Java锁等待唤醒机制

news2025/3/24 16:41:31

在 Java 并发编程中，锁的等待和唤醒机制至关重要，通常使用 wait()、notify() 和 notifyAll() 来实现线程间的协调。本文将详细介绍这些方法的用法，并通过示例代码加以说明。

1. `wait()`、`notify()` 与 `notifyAll()`

在 Java 中，Object 类提供了 wait()、notify() 和 notifyAll() 方法，它们用于线程间的通信。

wait()：使当前线程进入等待状态，并释放锁。
notify()：唤醒单个等待线程。
notifyAll()：唤醒所有等待线程。

注意，这些方法必须在同步代码块（synchronized）中调用，否则会抛出 IllegalMonitorStateException。

2. 示例代码

下面的示例展示了 wait() 和 notify() 的使用。

class SharedResource {
    private boolean available = false;
    
    public synchronized void produce() {
        while (available) {
            try {
                wait();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
        System.out.println("Producing an item");
        available = true;
        notify();
    }
    
    public synchronized void consume() {
        while (!available) {
            try {
                wait();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
        System.out.println("Consuming an item");
        available = false;
        notify();
    }
}

public class WaitNotifyExample {
    public static void main(String[] args) {
        SharedResource resource = new SharedResource();
        
        Thread producer = new Thread(resource::produce);
        Thread consumer = new Thread(resource::consume);
        
        producer.start();
        consumer.start();
    }
}

3. `wait()` 和 `notify()` 的工作原理

生产者线程 produce() 在 available 为 true 时调用 wait() 进入等待状态，释放锁。
消费者线程 consume() 在 available 为 false 时调用 wait() 进入等待状态，释放锁。
produce() 生产后调用 notify() 唤醒 consume()。
consume() 消费后调用 notify() 唤醒 produce()。

4. `notifyAll()` 的使用场景

notify() 仅唤醒一个线程，而 notifyAll() 可用于有多个等待线程的情况，以防止某些线程被永久阻塞。

public synchronized void produce() {
    while (available) {
        try {
            wait();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
    System.out.println("Producing an item");
    available = true;
    notifyAll();
}

5. `Lock` 和 `Condition` 方式

除了 synchronized，还可以使用 Lock 和 Condition 进行等待和唤醒控制。

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

class SharedResourceWithLock {
    private boolean available = false;
    private final Lock lock = new ReentrantLock();
    private final Condition condition = lock.newCondition();
    
    public void produce() {
        lock.lock();
        try {
            while (available) {
                condition.await();
            }
            System.out.println("Producing an item");
            available = true;
            condition.signal();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            lock.unlock();
        }
    }
    
    public void consume() {
        lock.lock();
        try {
            while (!available) {
                condition.await();
            }
            System.out.println("Consuming an item");
            available = false;
            condition.signal();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            lock.unlock();
        }
    }
}