本文共 2066 字,大约阅读时间需要 6 分钟。
最近看了阿里代码规范,较之前相比加入了许多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(); @Override public 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)); }}
1、例子中我假设做了10次检查,对应10个异步的子线程。
2、在子线程执行时,主线程等待(latch.await())。 3、子线程每次执行完退出前计数器减1。 4、等所有子线程全部执行完毕(计数器为0),此时执行主线程(发射火箭)。1、测试结果很明显ThreadLocalRandom要快很多,数据越大时越准确(我的结果是9010和5007,能优化至少1/3)。
2、原理:多线程在访问Random()时会有竞争,导致性能下降(线程饥饿)。而ThreadLocalRandom是jdk1.7后提供的并发产生随机数,能够解决多个线程发生的竞争。 3、想要更深了解的可以查看jdk源码。转载地址:http://jmrai.baihongyu.com/