Java并发编程中的CountDownLatch问题示例

原创﹏ヽ暗。殇╰゛Y 2024-09-06 05:51 60阅读 0赞

在Java的并发编程中，CountDownLatch是一种同步工具，它用于协调多个线程的活动。

以下是一个CountDownLatch问题示例：

```java
import java.util.concurrent.CountDownLatch;

class Producer {
    private CountDownLatch signal;
    
    public Producer(CountDownLatch signal) {
        this.signal = signal;
    }
    
    public void produce() throws InterruptedException {
        // 生产逻辑
        for (int i = 0; i < 10; i++) {
            Thread.sleep(100); // 模拟耗时操作
        }
        
        // 通知消费者生产已完成
        signal.countDown();
    }
}

class Consumer {
    private CountDownLatch signal;

public Consumer(CountDownLatch signal) {
        this.signal = signal;
    }

public void consume() throws InterruptedException {
        // 等待生产完成，信号计数为0后开始消费
        signal.await();

// 消费逻辑
        for (int i = 0; i < 5; i++) {
            System.out.println("Consumed item: " + i);
            Thread.sleep(200); // 模拟耗时操作
        }
    }
}

public class Main {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch signal = new CountDownLatch(1);

// 生产者
        new Thread(new Producer(signal))).start();

// 消费者
        new Thread(new Consumer(signal))).start();
    }
}
```

在这个示例中，我们创建了一个生产者线程和一个消费者线程。CountDownLatch用于协调两个线程的活动：当生产者完成10个元素的生产后，它会调用`countDown()`方法，将信号计数减为0。这时，消费者线程会在等待计数为0时开始消费。