Java 提供了一种更灵活和高级的线程协作机制，通过 Condition 接口的使用，你可以更精细地控制线程的等待和唤醒，实现更复杂的线程同步和通信。本文将详细介绍 Java 的 Condition 接口，包括它的基本概念、常见用法以及注意事项。
什么是 Condition 接口？
在 Java 多线程编程中，通常使用 wait() 和 notify() 方法来实现线程之间的等待和唤醒操作。但这两个方法有一些局限性，例如，只能在 synchronized 块内调用，而且每个对象只有一个等待队列。Condition 接口的引入弥补了这些不足，它提供了更灵活的线程协作方式。
Condition 接口是 Java 核心库中 java.util.concurrent.locks 包下的一部分，它通常与 ReentrantLock 一起使用。ReentrantLock 是一种可重入锁，与传统的 synchronized 关键字相比，提供了更多的控制和功能。通过 Condition 接口，你可以为每个 ReentrantLock 创建多个条件（Condition），每个条件可以控制一组线程的等待和唤醒。
Condition 接口的主要方法
Condition 接口定义了一些重要的方法，用于线程的等待和唤醒：
await()：使当前线程等待，并释放锁，直到其他线程调用相同条件上的signal()或signalAll()方法来唤醒它。awaitUninterruptibly()：与await()类似，但不响应中断。signal()：唤醒一个在该条件上等待的线程。如果有多个线程在等待，只会唤醒其中一个，具体唤醒哪个线程不确定。signalAll()：唤醒所有在该条件上等待的线程。
Condition 的基本用法
创建 Condition
要使用 Condition 接口，首先需要创建一个与 ReentrantLock 关联的条件对象。通常，一个 ReentrantLock 对象可以创建多个条件对象，用于不同的线程协作。
ReentrantLock lock = new ReentrantLock();
Condition condition = lock.newCondition();等待和唤醒线程
在使用 Condition 进行线程协作时，通常遵循以下模式：
等待线程
代码语言：javascript复制lock.lock(); // 获取锁
try {
while (条件不满足) {
condition.await(); // 释放锁，并等待条件满足
}
// 执行线程任务
} finally {
lock.unlock(); // 释放锁
}唤醒线程
代码语言：javascript复制lock.lock(); // 获取锁
try {
// 修改条件，使等待线程可以继续执行
condition.signal(); // 唤醒一个等待线程
// 或者使用 condition.signalAll() 唤醒所有等待线程
} finally {
lock.unlock(); // 释放锁
}示例：生产者和消费者问题
让我们通过一个简单的生产者和消费者问题来演示 Condition 的使用。在这个问题中，有一个有界缓冲区，生产者线程将数据放入缓冲区，而消费者线程将数据从缓冲区取出。
首先，我们创建一个有界缓冲区的类：
代码语言：javascript复制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 BoundedBuffer<T> {
private Queue<T> buffer = new LinkedList<>();
private int capacity;
private Lock lock = new ReentrantLock();
private Condition notFull = lock.newCondition();
private Condition notEmpty = lock.newCondition();
public BoundedBuffer(int capacity) {
this.capacity = capacity;
}
public void put(T item) throws InterruptedException {
lock.lock();
try {
while (buffer.size() == capacity) {
notFull.await();
}
buffer.offer(item);
notEmpty.signal();
} finally {
lock.unlock();
}
}
public T take() throws InterruptedException {
lock.lock();
try {
while (buffer.isEmpty()) {
notEmpty.await();
}
T item = buffer.poll();
notFull.signal();
return item;
} finally {
lock.unlock();
}
}
}在这个示例中，我们使用了 ReentrantLock 来保护缓冲区的操作，并分别创建了两个条件 notFull 和 notEmpty，用于控制缓冲区的状态。
接下来，我们可以创建生产者和消费者线程，它们分别向缓冲区放入数据和取出数据：
代码语言：javascript复制public class ProducerConsumerExample {
public static void main(String[] args) {
BoundedBuffer<Integer> buffer = new BoundedBuffer<>(10);
Thread producerThread = new Thread(() -> {
try {
for (int i = 0; i < 100; i ) {
buffer.put(i);
System.out.println("Produced: " i);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
Thread consumerThread = new Thread(() -> {
try {
for (int i = 0; i < 100; i ) {
int item = buffer.take();
System.out.println("Consumed: " item);
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
});
producerThread.start();
consumerThread.start();
}
}在这个示例中，生产者线程不断地向缓冲区放入数据，而消费者线程不断地从缓冲区取出数据，它们通过 await() 和 signal() 方法进行线程协作。
注意事项
在使用 Condition 接口时，需要注意以下几点：
- 必须在获取锁之后才能调用
await()、signal()和signalAll()方法，否则会抛出IllegalMonitorStateException异常。 - 调用
await()方法后，当前线程将释放锁，允许其他线程获取锁并执行。当线程被唤醒后，它将重新尝试获取锁，然后从await()方法返回。 -
signal()方法只能唤醒一个等待线程，如果有多个线程在等待，具体唤醒哪一个是不确定的。如果需要唤醒所有等待线程，可以使用signalAll()方法。 - 在等待时，通常需要将
await()方法包装在一个循环中，以防止虚假唤醒。 - 使用
Condition接口时，要特别小心死锁和竞态条件等多线程问题，确保线程协作的正确性和安全性。
总结
Condition 接口提供了一种更灵活和高级的线程协作机制，可以用于实现复杂的线程同步和通信。通过创建多个条件对象，你可以更精细地控制线程的等待和唤醒。但在使用时需要小心处理锁和条件的关系，以确保线程协作的正确性和可靠性。希望本文对你理解和应用 Condition 接口有所帮助，提高多线程编程的技能。
