Java如何使用Lock与Condition实现等待唤醒机制_Java同步锁的进阶使用-java教程-PHP中文网

Java如何使用Lock与Condition实现等待唤醒机制_Java同步锁的进阶使用

P粉602998670

发布： 2025-11-18 10:49:02

原创

554人浏览过

Lock与Condition可实现精准线程协作，如生产者消费者模型中通过notFull和notEmpty两个条件实现双向等待唤醒，相比synchronized更灵活，支持多条件、公平锁及中断响应，需注意锁的释放与唤醒策略。

java如何使用lock与condition实现等待唤醒机制_java同步锁的进阶使用

在Java多线程编程中，Lock 和 Condition 提供了比synchronized更灵活的线程同步控制方式。通过它们可以实现精确的等待唤醒机制，尤其适用于复杂的线程协作场景。

Lock与Condition的基本概念

Lock接口是synchronized的增强替代方案，支持更细粒度的锁控制。而Condition则类似于Object的wait()和notify()，但功能更强大，允许一个Lock绑定多个Condition实例。

使用步骤如下：

创建ReentrantLock实例作为锁
调用lock.newCondition()获取Condition对象
线程在条件不满足时调用condition.await()进入等待状态
其他线程改变状态后调用condition.signal()或signalAll()唤醒等待线程

实现生产者消费者模型

下面是一个典型的生产者消费者示例，展示如何用Lock+Condition协调两个线程：

立即学习“Java免费学习笔记（深入）”；

无阶未来模型擂台/AI 应用平台

无阶未来模型擂台/AI 应用平台，一站式模型+应用平台

查看详情

import java.util.LinkedList;
import java.util.concurrent.locks.*;

public class ProducerConsumer {
    private final LinkedList<String> buffer = new LinkedList<>();
    private final int MAX_SIZE = 5;
    private final Lock lock = new ReentrantLock();
    private final Condition notFull = lock.newCondition();
    private final Condition notEmpty = lock.newCondition();

    public void produce(String data) throws InterruptedException {
        lock.lock();
        try {
            while (buffer.size() == MAX_SIZE) {
                System.out.println("缓冲区满，生产者等待...");
                notFull.await();
            }
            buffer.add(data);
            System.out.println("生产：" + data);
            notEmpty.signal(); // 唤醒消费者
        } finally {
            lock.unlock();
        }
    }

    public String consume() throws InterruptedException {
        lock.lock();
        try {
            while (buffer.isEmpty()) {
                System.out.println("缓冲区空，消费者等待...");
                notEmpty.await();
            }
            String data = buffer.removeFirst();
            System.out.println("消费：" + data);
            notFull.signal(); // 唤醒生产者
            return data;
        } finally {
            lock.unlock();
        }
    }
}

登录后复制

这个例子中，notFull用于生产者等待，notEmpty用于消费者等待，实现了双向通信。