Java并发编程：CountDownLatch的正确使用示例

原创拼搏现实的明天。 2024-10-21 23:33 47阅读 0赞

CountDownLatch是一种同步工具，它用于协调多个线程。当一个线程调用`countDown()`方法时，CountDownLatch的计数器会减1。

下面是一个CountDownLatch的正确使用示例：

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

public class CountDownLatchExample {
    private CountDownLatch countDownLatch;
    private int numThreads;

public CountDownLatchExample(int numThreads) {
        this.numThreads = numThreads;
        this.countDownLatch = new CountDownLatch(numThreads);
    }

public void startThreads() throws InterruptedException {
        for (int i = 0; i < numThreads; i++) {
            Thread thread = new Thread(() -> {
                // 线程执行的代码
                System.out.println("Thread " + i + " is executing...");
                
                // 当线程需要通知其他线程时，调用countDown()
                countDownLatch.countDown();
            }));
            
            thread.start();
        }
    }

public static void main(String[] args) throws InterruptedException {
        CountDownLatchExample example = new CountDownLatchExample(5); // 创建一个包含5个线程的示例
        example.startThreads(); // 启动线程

// 主线程会等待所有子线程完成
        countDownLatch.await();
        
        System.out.println("All threads have completed!");
    }
}
```

在这个示例中，我们创建了一个包含5个线程的CountDownLatchExample。每个线程都会调用`countDown()`方法来减少CountDownLatch的计数器。

主线程会等待所有子线程完成，这通过调用`countDownLatch.await();`实现。