本文主要是介绍阿里规范(一)关于CountDownLatch和ThreadLocalRandom的详解(带测试代码),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!
最近看了阿里代码规范,较之前相比加入了许多java的新特性。最新的文档有一定的门槛,比如有些是阿里dubbo特有的规范,可能我们用不到,只需结合自身实际合理借鉴即可。给我印象最深的是集合和线程的规范,这两部分我写了不少的测试例子,写几篇博客给大家分享一下,喜欢的可以点击关注。(笔者推荐学习文档时配合阿里代码扫描插件,有eclipse版idea版)。
阿里规范原文(1):使用 CountDownLatch 进行异步转同步操作,每个线程退出前必须调用 countDown 方法,线程执行代码注意 catch 异常,确保 countDown 方法被执行到,避免主线程无法执行至 await 方法,直到超时才返回结果。
阿里规范原文(2):避免 Random 实例被多线程使用,虽然共享该实例是线程安全的,但会因竞争同一seed 导致的性能下降。在 JDK7 之后,可以直接使用 API ThreadLocalRandom,而在 JDK7 之前,需要编码保证每个线程持有一个实例。
这两个规范我放在一个例子里测试,大家可以直接复制运行。
业务场景
火箭发射前需要做各种检查,等各种检查完毕之后,点火,火箭发射。在这里发射前的各种检查是并行的(文档中的异步),检查和火箭发射是有顺序要求的(同步)。
测试代码
public class CountDownLatchDemo implements Runnable{static final CountDownLatch latch = new CountDownLatch(10);static final CountDownLatchDemo demo = new CountDownLatchDemo();@Overridepublic void run() {// 模拟检查任务try {/**测试多线程情况下 Random 和 ThreadLocalRandom 的性能, 对应文档的1.6.14 */Thread.sleep(ThreadLocalRandom.current().nextInt(10) * 1000);//Thread.sleep(new Random().nextInt(10) * 1000);//System.out.println("check complete");//计数减一latch.countDown();} catch (InterruptedException e) {e.printStackTrace();}}public static void main(String[] args) throws InterruptedException {long currentTimeMillis = System.currentTimeMillis();ExecutorService exec = Executors.newFixedThreadPool(10);for (int i=0; i<100; i++){exec.submit(demo);}// 等待火箭发射前的各种检查(主线程等待所有子线程执行完成,再向下执行)latch.await();// 发射火箭System.out.println("Fire!");// 关闭线程池exec.shutdown();System.out.println("耗时:" + (System.currentTimeMillis() - currentTimeMillis));}
}
说明一(CountDownLatch )
1、例子中我假设做了10次检查,对应10个异步的子线程。
2、在子线程执行时,主线程等待(latch.await())。
3、子线程每次执行完退出前计数器减1。
4、等所有子线程全部执行完毕(计数器为0),此时执行主线程(发射火箭)。
说明二(ThreadLocalRandom)
1、测试结果很明显ThreadLocalRandom要快很多,数据越大时越准确(我的结果是9010和5007,能优化至少1/3)。
2、原理:多线程在访问Random()时会有竞争,导致性能下降(线程饥饿)。而ThreadLocalRandom是jdk1.7后提供的并发产生随机数,能够解决多个线程发生的竞争。
3、想要更深了解的可以查看jdk源码。
这篇关于阿里规范(一)关于CountDownLatch和ThreadLocalRandom的详解(带测试代码)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!