Java并发编程中，条件变量的使用示例

原创深藏阁楼爱情的钟 2024-11-07 11:48 13阅读 0赞

在Java并发编程中，条件变量通常用于多线程之间的协调，使得一个线程可以等待某个条件成立，而其他线程可以改变这个条件。Java并没有直接提供条件变量，但是可以通过`Object`类的`wait()`和`notify()`/`notifyAll()`方法来实现条件变量的功能。

以下是一个简单的示例，展示如何使用`wait()`和`notify()`方法来模拟条件变量的行为：

```javapublic class ConditionVariableExample {

private static class Task {
 private boolean isReady = false;
 private boolean isProcessed = false;

public synchronized void waitForReady() throws InterruptedException {
 while (!isReady) {
 wait();
 }
 }

public synchronized void markReady() {
isReady = true;
 notifyAll();
 }

public synchronized void waitForProcessed() throws InterruptedException {
 while (!isProcessed) {
 wait();
 }
 }

public synchronized void markProcessed() {
isProcessed = true;
 notifyAll();
 }
 }

private static class Producer extends Thread {
 private Task task;

public Producer(Task task) {
 this.task = task;
 }

public void run() {
 System.out.println("Producer is marking task as ready.");
 task.markReady();
 }
 }

private static class Consumer extends Thread {
 private Task task;

public Consumer(Task task) {
 this.task = task;
 }

public void run() {
 try {
 task.waitForReady();
 System.out.println("Consumer is processing the task.");
//模拟处理任务Thread.sleep(1000);
 task.markProcessed();
} catch (InterruptedException e) {
e.printStackTrace();
 }
 }
 }

public static void main(String[] args) {
 Task task = new Task();

Producer producer = new Producer(task);
 Consumer consumer = new Consumer(task);

producer.start();
 consumer.start();
 }
}
```在这个示例中，我们定义了一个`Task`类，它有两个状态：`isReady`和`isProcessed`。`Producer`线程会标记任务为就绪，而`Consumer`线程会等待任务就绪，然后处理它，并标记为已处理。

- `markReady()`方法会将`isReady`设置为`true`，并通知所有等待的线程。
- `waitForReady()`方法会检查`isReady`是否为`true`，如果不是，则调用`wait()`方法等待。
- `markProcessed()`方法会将`isProcessed`设置为`true`，并通知所有等待的线程。
- `waitForProcessed()`方法会检查`isProcessed`是否为`true`，如果不是，则调用`wait()`方法等待。

请注意，使用`wait()`和`notify()`/`notifyAll()`时，必须在同步块或同步方法中调用，以确保线程安全。此外，调用`wait()`的线程会释放对象的锁，直到被`notify()`/`notifyAll()`唤醒后重新获取锁。