Java CountDownLatch 实例解析

需积分: 10 1 下载量 86 浏览量 更新于2024-09-17 收藏 3KB TXT 举报
"Java中的CountDownLatch是一个并发工具类,用于协调多个线程之间的协作,使得在某个线程或一组线程执行完毕后再继续其他线程的执行。它是一个计数器,初始值由构造函数传入,每次调用countDown()方法会减少计数值,直到计数器变为0,此时所有等待在await()方法上的线程会被释放并继续执行。这个机制常用于多线程的启动同步或者等待所有任务完成的场景。 在提供的代码示例中,CountDownLatch被用来模拟一场有5位运动员的比赛。首先创建了一个CountDownLatch实例`begin`,计数值为1,表示比赛开始的信号。当所有运动员准备就绪后,主线程调用`begin.countDown()`发送开始信号。接着创建了另一个CountDownLatch实例`end`,计数值为5,表示所有运动员都完成比赛。 每个运动员(Player类)都有自己的线程,并持有一个开始`begin`和结束`end`的CountDownLatch引用。运动员在run()方法中调用`begin.await()`等待比赛开始,然后模拟随机完成时间,最后调用`end.countDown()`表示自己已经完成比赛。主线程调用`end.wait()`等待所有运动员完成比赛,直到`end`的计数器归0,比赛结束。 这段代码展示了CountDownLatch如何在实际场景中使用,确保所有运动员都在比赛开始后才开始跑,并且主线程会等待所有运动员都完成比赛才会打印出"Race ends!",实现了线程间的同步和协调。" 这段代码的执行流程如下: 1. 创建`CountDownLatchDemo`对象,初始化`begin`和`end`。 2. 创建5个`Player`对象,每个运动员对应一个线程,运动员线程持有关于开始和结束的CountDownLatch引用。 3. 使用固定大小的线程池`ExecutorService`来执行运动员线程。 4. 主线程调用`begin.countDown()`,比赛开始信号释放。 5. 运动员线程在`begin.await()`处阻塞,等待比赛开始信号。 6. 每个运动员线程随机模拟比赛完成,然后调用`end.countDown()`。 7. 主线程调用`end.wait()`,等待所有运动员完成比赛。 8. 当所有运动员完成(`end`计数器减至0),主线程打印"Race ends!",比赛结束。 9. 关闭线程池,程序结束。
2023-05-26 上传