Java中并发工具类如CountDownLatch的应用示例

原创客官°小女子只卖身不卖艺 2024-09-12 07:09 92阅读 0赞

CountDownLatch是一个多线程同步工具，它在一个或多个线程执行完特定操作后，通过调用down方法将计数器的值减1。当所有线程完成任务并将计数器减少到0时，CountDownLatch会自动触发一个屏障，使得后续的线程等待。

下面是一个简单的示例，展示了如何使用CountDownLatch来控制多个线程的执行：

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

public class CountDownLatchExample {
    private static final int THREAD_COUNT = 5; // 要创建的线程数
    private static final int LOCKED_COUNT = 3; // 计数器的初始值

public static void main(String[] args) {
        CountDownLatch countDownLatch = new CountDownLatch(THREAD_COUNT); // 创建CountDownLatch

for (int i = 0; i < THREAD_COUNT; i++) { // 创建并启动线程
            new Thread(() -> {
                try {
                    countDownLatch.await(LOCKED_COUNT, TimeUnit.SECONDS)); // 等待计数器减少到指定值
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }).start();
        }

// 在所有线程完成任务后，调用down方法将计数器减1
        countDownLatch.countDown();

System.out.println("All threads finished. Closing the program..."); // 输出最终信息

// 程序关闭
    }
}
```

在这个示例中，我们创建了5个线程，每个线程都会调用CountDownLatch的await方法来等待计数器减少到3。当所有线程完成任务后，我们会调用countDown方法将计数器减1，表示所有的线程都已经完成了它们的任务。