Java多线程同步问题：CountDownLatch实战案例

原创待我称王封你为后i 2024-09-25 05:18 102阅读 0赞

`CountDownLatch`是Java并发工具包（java.util.concurrent）中的一个类，主要用于协调多个线程的执行。

下面是一个简单的实战案例，描述了两个生产者线程和一个消费者线程如何通过`CountDownLatch`实现同步：

1. **创建CountDownLatch**：
```java
CountDownLatch countDownLatch = new CountDownLatch(3); // 指定信号量初始值为3，表示至少有三个事件发生后才会关闭countDownLatch
```

2. **生产者线程示例**：
```java
// 生产者1
class Producer1 extends Thread {
    @Override
    public void run() {
        try {
            // 创建产品，并增加CountDownLatch信号量
            countDownLatch.countDown();
            System.out.println("Producer 1 created product and signal is down");

// 休眠一段时间，模拟生产过程
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

// 生产者2
class Producer2 extends Thread {
    @Override
    public void run() {
        try {
            countDownLatch.countDown();
            System.out.println("Producer 2 created product and signal is down");

// 休眠一段时间，模拟生产过程
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

// 创建并启动两个生产者线程
Producer1 producer1 = new Producer1();
producer1.start();

Producer2 producer2 = new Producer2();
producer2.start();
```

3. **消费者线程示例**：
```java
// 消费者
class Consumer extends Thread {
    @Override
    public void run() {
        try {
            // 确保至少有三个事件发生后，才开始消费
            countDownLatch.await(10, TimeUnit.SECONDS)); 
            System.out.println("Consumer started to consume after the signal was up for 10 seconds");

// 休眠一段时间，模拟消费者消费过程
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

// 创建并启动一个消费者线程
Consumer consumer = new Consumer();
consumer.start();
```

这个案例展示了如何使用`CountDownLatch`来协调多个线程的执行，确保至少有三个事件发生后，消费者线程才会开始消费。