Java CountDownLatch 实例解析

需积分: 10 1 下载量 124 浏览量 更新于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. 关闭线程池,程序结束。
2016-06-10 上传
实验七 Java多线程 一、实验目的: 熟悉利用Thread类建立多线程方法。 熟悉利用Thread接口建立多线程方法。 二、实验内容: 1. 阅读下列程序,分析并上机检验其功能。 class DelayThread exends Thread{ private static int count=0; private int no; private int delay; public DelayThread(){ count++; no=count; } public void run(){ try{ for (int i=0;i<10;i++){ delay=(int)(Math.random()*5000); sleep(delay); System.out.println(“Thread ”+no+” with a delay ”+delay); } }catch(InterruptedException e){}}} public class MyThread{ public static void main(String args[]){ DelayThread thread1=new DelayThread(); DelayThread thread2=new DelayThread(); thread1.start(); thread2.start(); try{ Thread.sleep(1000);}catch(InterruptedException e){ System.out.println(“Thread wrong”);}}} 2.讲上列程序利用Runnable接口改写,并上机检验。 3.利用多线程编写一个模拟时钟(AWT程序、Runnable接口),有时/分/秒针 编写一个应用程序,创建三个线程分别显示各自的时间。 三、实验要求: 1. 通过实验掌握Thread 、Runnable使用方法; 2. 程序必须能够实现多线程; 3. 程序必须能够完成题目要求; 4. 写出实验报告。 四、实验步骤: 首先分析程序功能,再通过上机运行验证自己的分析,从而掌握通过Thread类建立多线程的方法。 通过将扩展Thread类建立多线程的方法改为利用Runnable接口的方法,掌握通过Runnable接口建立多线程的方法。
2023-05-26 上传