Java中CountDownLatch用法详解编程语言
2023-06-13 09:20:29 时间
CountDownLatch类是一个同步计数器,构造时传入int参数,该参数就是计数器的初始值,每调用一次countDown()方法,计数器减1,计数器大于0 时,await()方法会阻塞程序继续执行
CountDownLatch如其所写,是一个倒计数的锁存器,当计数减至0时触发特定的事件。利用这种特性,可以让主线程等待子线程的结束。下面以一个模拟运动员比赛的例子加以说明。
import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; public class CountDownLatchDemo { private static final int PLAYER_AMOUNT = 5; public CountDownLatchDemo() { // TODO Auto-generated constructor stub /** * @param args public static void main(String[] args) { // TODO Auto-generated method stub //对于每位运动员,CountDownLatch减1后即结束比赛 CountDownLatch begin = new CountDownLatch(1); //对于整个比赛,所有运动员结束后才算结束 CountDownLatch end = new CountDownLatch(PLAYER_AMOUNT); Player[] plays = new Player[PLAYER_AMOUNT]; for(int i=0;i PLAYER_AMOUNT;i++) plays[i] = new Player(i+1,begin,end); //设置特定的线程池,大小为5 ExecutorService exe = Executors.newFixedThreadPool(PLAYER_AMOUNT); for(Player p:plays) exe.execute(p); //分配线程 System.out.println("Race begins!"); begin.countDown(); try{ end.await(); //等待end状态变为0,即为比赛结束 }catch (InterruptedException e) { // TODO: handle exception e.printStackTrace(); }finally{ System.out.println("Race ends!"); exe.shutdown(); }
接下来是Player类
`java import java.util.concurrent.CountDownLatch;
public class Player implements Runnable {
private int id; private CountDownLatch begin; private CountDownLatch end; public Player(int i, CountDownLatch begin, CountDownLatch end) { // TODO Auto-generated constructor stub super(); this.id = i; this.begin = begin; this.end = end; @Override public void run() { // TODO Auto-generated method stub try{ begin.await(); //等待begin的状态为0 Thread.sleep((long)(Math.random()*100)); //随机分配时间,即运动员完成时间 System.out.println("Play"+id+" arrived."); }catch (InterruptedException e) { // TODO: handle exception e.printStackTrace(); }finally{ end.countDown(); //使end状态减1,最终减至0
} `
10444.html
cjava相关文章
- Java 8 的 java.util.function.* POJO 的反射新方法
- java输出一个数组的元素_Java输出数组元素「建议收藏」
- 从使用到原理学习Java线程池详解编程语言
- Java ThreadLocal深度解析详解编程语言
- 一致性Hash算法的Java实现详解编程语言
- java栈数据结构的LinkedList实现详解编程语言
- Java备份还原Mysql数据库详解编程语言
- Java 自带的加密类MessageDigest类(加密MD5和SHA)详解编程语言
- java音乐播放器-乐乐音乐播放器详解编程语言
- java 资源浏览器的图形化组件详解编程语言
- java 使用java执行命令简易封装类详解编程语言
- Java图片转换为base64格式详解编程语言
- Java实现zip解压缩目录中的所有文件详解编程语言
- Java获取本地IP方法详解编程语言
- JAVA生成解析二维码详解编程语言
- 常用的Java代码汇总详解编程语言
- Java实现打字练习的代码详解编程语言
- Java多线程下载文件详解编程语言
- 《Effect Java》 归纳总结详解编程语言
- Java连接HBase(kerberized集群)详解编程语言
- Java IO详解(三)——字节输入输出流编程语言
- Java中int和Integer的区别详解编程语言
- java上传图片文件和回显详解编程语言
- java不适合做单机web管理平台的2大因素详解编程语言
- Java定时任务工具详解之Timer篇编程语言
- Java经典实例:在正则表达式中控制大小写详解编程语言
- java中的锁详解编程语言
- Java中可变长参数的使用及注意事项详解编程语言
- php转java 系列2 Spring boo 链接数据库jdbc详解编程语言
- Java NIO 读取文件、写入文件、读取写入混合详解编程语言
- Java多线程21:多线程下的其他组件之CyclicBarrier、Callable、Future和FutureTask详解编程语言
- MacOS下Java开发环境搭建指南(macos开发java)
- Linux与Java结合:开启全新的编程之旅(linux java())