时间:2021-05-19
在java中我们通常会需要使用到java.util.Random来便利的生产随机数。但是Random是线程安全的,如果要在线程环境中的话就有可能产生性能瓶颈。
我们以Random中常用的nextInt方法为例来具体看一下:
public int nextInt() { return next(32); }nextInt方法实际上调用了下面的方法:
protected int next(int bits) { long oldseed, nextseed; AtomicLong seed = this.seed; do { oldseed = seed.get(); nextseed = (oldseed * multiplier + addend) & mask; } while (!seed.compareAndSet(oldseed, nextseed)); return (int)(nextseed >>> (48 - bits)); }从代码中我们可以看到,方法内部使用了AtomicLong,并调用了它的compareAndSet方法来保证线程安全性。所以这个是一个线程安全的方法。
其实在多个线程环境中,Random根本就需要共享实例,那么该怎么处理呢?
在JDK 7 中引入了一个ThreadLocalRandom的类。ThreadLocal大家都知道就是线程的本地变量,而ThreadLocalRandom就是线程本地的Random。
我们看下怎么调用:
ThreadLocalRandom.current().nextInt();我们来为这两个类分别写一个benchMark测试:
public class RandomUsage { public void testRandom() throws InterruptedException { ExecutorService executorService=Executors.newFixedThreadPool(2); Random random = new Random(); List<Callable<Integer>> callables = new ArrayList<>(); for (int i = 0; i < 1000; i++) { callables.add(() -> { return random.nextInt(); }); } executorService.invokeAll(callables); } public static void main(String[] args) throws RunnerException { Options opt = new OptionsBuilder() .include(RandomUsage.class.getSimpleName()) // 预热5轮 .warmupIterations(5) // 度量10轮 .measurementIterations(10) .forks(1) .build(); new Runner(opt).run(); }}public class ThreadLocalRandomUsage { @Benchmark @BenchmarkMode(Mode.AverageTime) @OutputTimeUnit(TimeUnit.MICROSECONDS) public void testThreadLocalRandom() throws InterruptedException { ExecutorService executorService=Executors.newFixedThreadPool(2); List<Callable<Integer>> callables = new ArrayList<>(); for (int i = 0; i < 1000; i++) { callables.add(() -> { return ThreadLocalRandom.current().nextInt(); }); } executorService.invokeAll(callables); } public static void main(String[] args) throws RunnerException { Options opt = new OptionsBuilder() .include(ThreadLocalRandomUsage.class.getSimpleName()) // 预热5轮 .warmupIterations(5) // 度量10轮 .measurementIterations(10) .forks(1) .build(); new Runner(opt).run(); }}分析运行结果,我们可以看出ThreadLocalRandom在多线程环境中会比Random要快。
本文的例子可以参考https://github.com/ddean2009/learn-java-concurrency/tree/master/ThreadLocalRandom
到此这篇关于java中ThreadLocalRandom的使用详解的文章就介绍到这了,更多相关java ThreadLocalRandom内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
Java使用continue语句的实例详解在Java中,如何使用使用continue语句?下面示例中,演示如何使用continue语句跳过循环(实现统计指定字母
Java中内存异常StackOverflowError与OutOfMemoryError详解使用Java开发,经常回遇到内存异常的情况,而StackOverfl
java中静态导入机制用法实例详解这里主要讲解了如何使用Java中静态机制的用法,这里提供了简单实例大家可以参考下。静态常量类在java开发中,我们会经常用到一
java开发中嵌套类的详解在java语言规范里面,嵌套类(NestedClasses)定义是:Anestedclassisanyclasswhosedeclar
Java中CountDownLatch进行多线程同步详解CountDownLatch介绍在前面的Java学习笔记中,总结了Java中进行多线程同步的几个方法:1