多线程编程进阶：基于CountDownLatch的复杂场景实例

原创￡神魔★判官ぃ 2024-10-27 15:42 16阅读 0赞

CountDownLatch是一种多线程同步工具，它在一个线程中等待一组或多组其他线程完成特定操作。当所有等待的线程调用countDown方法时，CountDownLatch会释放所有已等待的线程。

下面是一个基于CountDownLatch的复杂场景实例：

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

public class MultiThreadExample {
    private CountDownLatch countDownLatch;
    private int totalOperations = 1000; // 假设总操作数为1000

public MultiThreadExample() {
        countDownLatch = new CountDownLatch(totalOperations);
    }

// 多个线程进行操作，每个操作完成后调用countDown
    public void startThreads() {
        for (int i = 0; i < totalOperations; i++) {
            new Thread(() -> performOperation(i, countDownLatch))) {
                @Override
                public String toString() {
                    return "Thread-" + i;
                }
            }.start();
        }
    }

// 每个线程操作的逻辑
    private void performOperation(int index, CountDownLatch countDownLatch) {
        try {
            Thread.sleep(index * 10); // 假设每个操作需要10毫秒时间

System.out.println(Thread.currentThread().getName() + ": Operation completed at index " + index);
            countDownLatch.countDown();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        MultiThreadExample example = new MultiThreadExample();
        example.startThreads();
    }
}
```

这个例子中，我们创建了一个CountDownLatch实例。然后在多线程环境中，每个线程执行`performOperation`方法，该方法会在操作完成后调用countDown方法。

当所有线程完成它们的`performOperation`任务后，CountDownLatch会释放所有的等待线程。