Java并发编程：条件变量的正确使用示例

原创比眉伴天荒 2024-10-20 13:27 43阅读 0赞

在Java并发编程中，条件变量是一种用于线程间通信的工具。当一个条件满足时，它会通知等待的线程。

以下是一个正确的使用条件变量的示例：

假设我们有一个生产者（Producer）和消费者（Consumer），生产者负责生成产品，消费者负责消费产品。

```java
import java.util.concurrent.Condition;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ConditionVariableExample {
    private CountDownLatch countDown = new CountDownLatch(1);
    private ExecutorService executor = Executors.newSingleThreadExecutor();
    private Condition productAvailableCondition = new ProductAvailableCondition();

public void produce() throws InterruptedException {
        executor.execute(() -> {
            while (countDown.getCount() > 0) {
                try {
                    // 生产产品
                    System.out.println("Produced a product.");
                    countDown.countDown(); // 产品可用，通知消费者

// 模拟耗时操作，以展示条件变量的正确使用
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                    break;
                }
            }
        }));
    }

public void consume() throws InterruptedException {
        executor.execute(() -> {
            try {
                // 等待产品可用，然后消费产品
                countDown.await(); // 通知等待的线程
                System.out.println("Consumed a product.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));
    }

public class ProductAvailableCondition implements Condition {
        @Override
        public boolean isSatisfied() {
            return true; // 产品可用，返回true
        }

@Override
        public void condition_met() {}

@Override
        public void condition_failed() {}
    }

public static void main(String[] args) throws InterruptedException {
        ConditionVariableExample example = new ConditionVariableExample();
        example.produce(); // 生产者开始工作
        example.consume(); // 消费者开始工作
        example.countDown.await(); // 等待所有线程完成任务

System.out.println("All threads have completed their tasks.");
    }
}
```

在这个示例中，生产者（Produce）负责生成产品并通知条件变量。消费者（Consume）等待产品可用后消费产品。

当所有的线程都完成了他们的任务，`countDown.await();`会等待这个操作完成，确保所有线程都已经退出了它们的工作。