在Java中如何使用Condition实现线程条件等待_Condition条件等待技巧说明_技术教程

答案：Condition是Lock的辅助工具，通过await()、signal()实现线程等待与唤醒。使用while循环检查条件，配合多个Condition可精确控制生产者-消费者模型中的线程协作。

在Java中，Condition 是 java.util.concurrent.locks.Lock 接口的一部分，用于实现更细粒度的线程等待与唤醒机制。相比传统的 synchronized 和 wait()/notify()，Condition 提供了更灵活的控制方式，允许一个锁绑定多个等待条件。

Condition的基本原理

Condition 本质上是 Lock 的辅助工具，它通过 Lock.newCondition() 方法创建。每个 Condition 实例都对应一个等待队列，线程可以在特定条件下挂起或被唤醒。

常用方法包括：

await()：使当前线程等待，并释放锁，直到被 signal() 唤醒或中断。
signal()：唤醒一个等待中的线程。
signalAll()：唤醒所有等待该条件的线程。

使用Condition实现生产者-消费者模型

一个典型的使用场景是生产者-消费者问题。通过两个 Condition 分别表示“非满”和“非空”状态，可以精确控制读写线程的执行时机。

示例代码：

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

public class BoundedQueue {
    private final Queue queue = new LinkedList<>();
    private final int capacity;
    private final Lock lock = new ReentrantLock();
    private final Condition notFull = lock.newCondition();
    private final Condition notEmpty = lock.newCondition();

    public BoundedQueue(int capacity) {
        this.capacity = capacity;
    }

    public void put(T item) throws InterruptedException {
        lock.lock();
        try {
            while (queue.size() == capacity) {
                notFull.await(); // 队列满时等待
            }
            queue.offer(item);
            notEmpty.signal(); // 通知消费者有数据
        } finally {
            lock.unlock();
        }
    }

    public T take() throws InterruptedException {
        lock.lock();
        try {
            while (queue.isEmpty()) {
                notEmpty.await(); // 队列空时等待
            }
            T item = queue.poll();
            notFull.signal(); // 通知生产者可继续添加
            return item;
        } finally {
            lock.unlock();
        }
    }
}