Java中condition

在Java中，Condition是一个用于线程间通信的对象，它可以让线程在等待某个条件成立时进入等待状态，直到其他线程发出通知唤醒它。Condition通常与Lock一起使用，它提供了类似于Object.wait()和Object.notify()的功能，但是更加灵活和强大。

在使用Condition时，我们需要通过Lock对象的newCondition()方法来创建一个Condition对象，然后使用await()方法让线程进入等待状态，在条件满足时使用signal()或signalAll()方法来唤醒等待的线程。

例如，下面的代码演示了如何使用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 ProducerConsumerExample {
    private static final int CAPACITY = 5;
    private final Queue<Integer> queue = new LinkedList<>();

    private final Lock lock = new ReentrantLock();
    private final Condition notFull = lock.newCondition();
    private final Condition notEmpty = lock.newCondition();

    public void put(int value) throws InterruptedException {
        lock.lock();
        try {
            while (queue.size() == CAPACITY) {
                notFull.await();
            }
            queue.add(value);
            notEmpty.signal();
        } finally {
            lock.unlock();
        }
    }

    public int get() throws InterruptedException {
        lock.lock();
        try {
            while (queue.isEmpty()) {
                notEmpty.await();
            }
            int value = queue.poll();
            notFull.signal();
            return value;
        } finally {
            lock.unlock();
        }
    }
}

在这个例子中，我们使用了一个队列来作为缓冲区，当队列满时，生产者线程调用notFull.await()进入等待状态，直到消费者线程取走一个元素后再唤醒它；当队列空时，消费者线程调用notEmpty.await()进入等待状态，直到生产者线程放入一个元素后再唤醒它。这样就可以有效地控制生产者和消费者的速度，避免了队列溢出和下溢的情况。