Java并发编程：条件变量的应用实例

原创心已赠人 2024-10-12 11:33 66阅读 0赞

条件变量是Java并发工具包中的一个关键组件，主要应用于线程间的通信和协调。以下是一个简单的应用实例：

**例子：生产者消费者问题**

1. **定义两个共享资源：缓冲区和条件变量**

```java
int bufferSize = 10;
Queue<Integer> queue = new ArrayDeque<>(bufferSize);
Condition condition = new Condition(queue);
```

2. **创建两个线程角色：生产者和消费者**

```java
Thread producer = new Thread(() -> {
    try {
        for (int i = 0; i < 10; i++) {
            queue.put(i);
            System.out.println("Producer: Added " + i + " to buffer");
            condition.signal();
            // 稍微休息一下，模拟生产过程
            Thread.sleep(100);
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}));
Thread consumer = new Thread(() -> {
    try {
        while (!queue.isEmpty()) {
            int item = queue.poll();
            System.out.println("Consumer: Consumed " + item + " from buffer");
            condition.signalIfEmpty();
            // 稍微休息一下，模拟消费过程
            Thread.sleep(100);
        }
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}));
```

3. **运行两个线程**

```java
producer.start();
consumer.start();
```

4. **理解结果**

当生产者向缓冲区添加元素时，条件变量`condition`会被唤醒并发出信号。消费者线程在收到信号后会立即执行，并从缓冲区中取出元素进行消费。

通过这个例子，你可以更深入地理解和应用Java中的条件变量。