【Java】随机数原理 Random ThreadLocalRandom

2024-05-24 20:48

本文主要是介绍【Java】随机数原理 Random ThreadLocalRandom,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

大致生成原理:随机数由seed经过一定的转换生成。需要提供初始seed。每一次生成随机数时,先由老seed生成新seed,再根据新seed生成新的随机数。由于算法是固定的,所以如果初始seed一样,那么生成的随机数序列就是一样的,这就是为什么Java的随机数要被叫做“伪随机数”。数学逻辑这里不展开。
主要实现类有两个Random以及ThreadLocalRandom。这两个都是线程安全的,区别在于解决并发生成新seed的方式不一样。Random是通过cas+自旋的方式,所以高并发场景下会有竞争,可能造成性能瓶颈。ThreadLocalRandom从名字就可以看出,使用了ThreadLocal的思想,每一个线程都有自己的seed,所以不存在竞争,在多线程场景下性能更好.下面看下具体实现:

Random:
首先看下Random的无参构造函数,提供了初始seed的生成逻辑:

private static final AtomicLong seedUniquifier = new AtomicLong(8682522807148012L);
public Random() {this(seedUniquifier() ^ System.nanoTime());
}private static long seedUniquifier() {long current;long next;do {current = seedUniquifier.get();next = current * 1181783497276652981L;} while(!seedUniquifier.compareAndSet(current, next));return next;
}public Random(long seed) {this.haveNextNextGaussian = false;if (this.getClass() == Random.class) {this.seed = new AtomicLong(initialScramble(seed));} else {this.seed = new AtomicLong();this.setSeed(seed);}}

可以看到是通过seedUniquifier和System.nanoTime两个函数做位运算生成的。seedUniquifier这个函数应该是为了生成初始化的seed,该函数使用cas的方式生成一个quilifer。不同的Random实例都有不同的quilifer,quilifer是通过cas变换一个static的变量生成的。之后再调用一个有参的构造函数设置初始seed。
接下来看下nextInt函数:

private final AtomicLong seed;
protected int next(int bits) {AtomicLong seed = this.seed;long oldseed;long nextseed;do {oldseed = seed.get();nextseed = oldseed * 25214903917L + 11L & 281474976710655L;} while(!seed.compareAndSet(oldseed, nextseed));return (int)(nextseed >>> 48 - bits);
}

可以看到,这里是通过cas方式将老的seed生成一个新的seed,由于seed本身是一个成员变量,如果多线程并发生成,这里就会有竞争。生成好新的seed后,再通过位运算生成新的随机值。其他函数类似。

ThreadLocalRandom:
ThreadLocalRandom的构造函数是private的:

static final ThreadLocalRandom instance;
private ThreadLocalRandom() {
}

所以初始seed不能设置,由ThreadLocalRandom类提供。并且,ThreadLocalRandom类是单例模式。在调用其current方法时构造单例,这里首先通过PROBE变量看是否已经为当前thread初始化seed了,如果没有就走localInit逻辑:

static final void localInit() {int p = probeGenerator.addAndGet(-1640531527);int probe = p == 0 ? 1 : p;long seed = mix64(seeder.getAndAdd(-4942790177534073029L));Thread t = Thread.currentThread();U.putLong(t, SEED, seed);U.putInt(t, PROBE, probe);
}public static ThreadLocalRandom current() {if (U.getInt(Thread.currentThread(), PROBE) == 0) {localInit();}return instance;
}

localInit方法会调用mix64方法生成初始seed,然后将seed放入thread实例的变量里,同时设置probe标记位。所以每一个thread都有自己的seed。这里的seed和probe是通过unsafe包里的方法直接设置的:

private static final Unsafe U;
private static final long SEED;
private static final long PROBE;U = Unsafe.getUnsafe();
SEED = U.objectFieldOffset(Thread.class, "threadLocalRandomSeed");
PROBE = U.objectFieldOffset(Thread.class, "threadLocalRandomProbe");

在ThreadLocalRandom类里通过unsafe的方法获得了这两个实例变量的迁移量,这样就可以直接通过偏移量设置变量的值了。为什么是这种方式?还有待探究。

另外,Thread类里其实有这两个实例变量:

public class Thread implements Runnable {@Contended("tlr")long threadLocalRandomSeed;@Contended("tlr")int threadLocalRandomProbe;@Contended("tlr")int threadLocalRandomSecondarySeed;
}

再看下,生成int随机数的逻辑:

public int nextInt() {return mix32(this.nextSeed());
}private static int mix32(long z) {z = (z ^ z >>> 33) * -49064778989728563L;return (int)((z ^ z >>> 33) * -4265267296055464877L >>> 32);
}
final long nextSeed() {Thread t;long r;U.putLong(t = Thread.currentThread(), SEED, r = U.getLong(t, SEED) + -7046029254386353131L);return r;
}

先调用了nextSeed方法生成新seed,由于seed是线程独有的,不需要再像Random那样cas了,直接计算并设置新的seed即可。新的seed是在老的seed的基础上加了一个偏移。然后随机数根据新的seed并调用mix32方法生成新随机数。
 

这篇关于【Java】随机数原理 Random ThreadLocalRandom的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/999490

相关文章

springboot集成easypoi导出word换行处理过程

《springboot集成easypoi导出word换行处理过程》SpringBoot集成Easypoi导出Word时,换行符n失效显示为空格,解决方法包括生成段落或替换模板中n为回车,同时需确... 目录项目场景问题描述解决方案第一种:生成段落的方式第二种:替换模板的情况,换行符替换成回车总结项目场景s

SpringBoot集成redisson实现延时队列教程

《SpringBoot集成redisson实现延时队列教程》文章介绍了使用Redisson实现延迟队列的完整步骤,包括依赖导入、Redis配置、工具类封装、业务枚举定义、执行器实现、Bean创建、消费... 目录1、先给项目导入Redisson依赖2、配置redis3、创建 RedissonConfig 配

SpringBoot中@Value注入静态变量方式

《SpringBoot中@Value注入静态变量方式》SpringBoot中静态变量无法直接用@Value注入,需通过setter方法,@Value(${})从属性文件获取值,@Value(#{})用... 目录项目场景解决方案注解说明1、@Value("${}")使用示例2、@Value("#{}"php

SpringBoot分段处理List集合多线程批量插入数据方式

《SpringBoot分段处理List集合多线程批量插入数据方式》文章介绍如何处理大数据量List批量插入数据库的优化方案:通过拆分List并分配独立线程处理,结合Spring线程池与异步方法提升效率... 目录项目场景解决方案1.实体类2.Mapper3.spring容器注入线程池bejsan对象4.创建

线上Java OOM问题定位与解决方案超详细解析

《线上JavaOOM问题定位与解决方案超详细解析》OOM是JVM抛出的错误,表示内存分配失败,:本文主要介绍线上JavaOOM问题定位与解决方案的相关资料,文中通过代码介绍的非常详细,需要的朋... 目录一、OOM问题核心认知1.1 OOM定义与技术定位1.2 OOM常见类型及技术特征二、OOM问题定位工具

基于 Cursor 开发 Spring Boot 项目详细攻略

《基于Cursor开发SpringBoot项目详细攻略》Cursor是集成GPT4、Claude3.5等LLM的VSCode类AI编程工具,支持SpringBoot项目开发全流程,涵盖环境配... 目录cursor是什么?基于 Cursor 开发 Spring Boot 项目完整指南1. 环境准备2. 创建

Spring Security简介、使用与最佳实践

《SpringSecurity简介、使用与最佳实践》SpringSecurity是一个能够为基于Spring的企业应用系统提供声明式的安全访问控制解决方案的安全框架,本文给大家介绍SpringSec... 目录一、如何理解 Spring Security?—— 核心思想二、如何在 Java 项目中使用?——

SpringBoot+RustFS 实现文件切片极速上传的实例代码

《SpringBoot+RustFS实现文件切片极速上传的实例代码》本文介绍利用SpringBoot和RustFS构建高性能文件切片上传系统,实现大文件秒传、断点续传和分片上传等功能,具有一定的参考... 目录一、为什么选择 RustFS + SpringBoot?二、环境准备与部署2.1 安装 RustF

springboot中使用okhttp3的小结

《springboot中使用okhttp3的小结》OkHttp3是一个JavaHTTP客户端,可以处理各种请求类型,比如GET、POST、PUT等,并且支持高效的HTTP连接池、请求和响应缓存、以及异... 在 Spring Boot 项目中使用 OkHttp3 进行 HTTP 请求是一个高效且流行的方式。

java.sql.SQLTransientConnectionException连接超时异常原因及解决方案

《java.sql.SQLTransientConnectionException连接超时异常原因及解决方案》:本文主要介绍java.sql.SQLTransientConnectionExcep... 目录一、引言二、异常信息分析三、可能的原因3.1 连接池配置不合理3.2 数据库负载过高3.3 连接泄漏