caffeine 线程私有的ReadBuffer实现

Caffeine中，读操作后的afterRead操作都会异步操作，不会阻塞到正常的读取操作。

在高并发读取的前提下，为每个读取操作的线程建立了专属的buffer来存放afterRead事件由消费者统一处理afterRead事件，避免高并发读取下对于事件写入buffer的时候的资源竞争。

transient volatile Buffer<E>[] table;

StrippedBuffer中维护了一个Buffer[]数组table，用来存放各个线程专属的buffer。

如何界定某个buffer属于哪个线程去写入，又或者如何判断线程在写入的时候应该选择哪个buffer。

static final long PROBE = UnsafeAccess.objectFieldOffset(Thread.class, "threadLocalRandomProbe");
static final int getProbe() {return UnsafeAccess.UNSAFE.getInt(Thread.currentThread(), PROBE);
}

在为每个线程选择具体的buffer的时候，将会根据每个线程的ThreadLocalRandom来hash定位buffer数组的具体位置，每次需要定位的时候通过getProbe()方法，通过Unsafe来获取Thread的threadLocalRandomProbe随机数，通过hash的方式进行定位。

@Override
public int offer(E e) {int mask;int result = 0;Buffer<E> buffer;boolean uncontended = true;Buffer<E>[] buffers = table;if ((buffers == null)|| (mask = buffers.length - 1) < 0|| (buffer = buffers[getProbe() & mask]) == null|| !(uncontended = ((result = buffer.offer(e)) != Buffer.FAILED))) {expandOrRetry(e, uncontended);}return result;
}

当事件具体准备通过offer()方法根据线程的ThreadLocal随机数选择到具体的buffer数组table上的位置，并进行写入。

其中，可能会出现buffer数组没初始化，buffer数组对应位置上的buffer还没初始化完成，buffer由于hash碰撞被并发写入导致一个线程的写入失败，几种情况，这几种情况会通过expandOrRetry()方法进行重试或者扩容。

transient volatile int tableBusy;
final boolean casTableBusy() {return UnsafeAccess.UNSAFE.compareAndSwapInt(this, TABLE_BUSY, 0, 1);
}

在扩容过程中，通过cas修改tablrBusy的量保证线程安全。

caffeine 线程私有的ReadBuffer实现相关推荐

并发编程02-什么是线程安全以及Java虚拟机中哪些数据是线程共享的，那些是线程私有的
线程安全的本质什么是线程安全要说什么是线程安全,那么我们看看生活中例子吧. 场景1:王菲要来西安体育场开演唱会,这个体育场规模不是很大,能容纳1000个人,于是准备了1000张票,后天中午12点在 ...
本地方法栈线程公有_Java运行时区域，哪些区域是线程私有的？哪些是共有的？...
JVM 运行时数据区域大致可以分为:程序计数器.虚拟机栈.本地方法栈.堆区.元空间.运行时常量池.直接内存等区域:就是下面这个样子的: 其中有些区域,随着 JDK 版本的升级不断调整,例如: JDK ...
聊一聊Spring中的线程安全性
原文出处:SylvanasSun Spring与线程安全 ThreadLocal ThreadLocal中的内存泄漏参考文献 Spring与线程安全 Spring作为一个IOC/DI容器,帮助我们管 ...
java线程的优先级是数字越大优先级越高_《深入理解Java虚拟机》5分钟速成：12章（Java内存模型与线程）...
第12章 Java内存模型与线程前言: 1.物理机如何处理并发问题? 2.什么是Java内存模型? 3.原子性.可见性.有序性的具体含义和应用实现? 4.volatile 关键字特性? 5.基于vo ...
Spring 中的bean 是线程安全的吗？
点击上方蓝色"方志朋",选择"设为星标" 回复"666"获取独家整理的学习资料! 作者:myseries cnblogs.com/myser ...
聊一聊 Spring 中的线程安全性
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章作者 | SylvanasSun 来源 | juejin.im/p ...
今天我们来聊一聊 Spring 中的线程安全性
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章 Spring与线程安全 Spring作为一个IOC/DI容器,帮助 ...
controller如何保证当前只有一个线程执行_今天我们来聊一聊 Spring 中的线程安全性...
优质文章,及时送达 Spring与线程安全 Spring作为一个IOC/DI容器,帮助我们管理了许许多多的"bean".但其实,Spring并没有保证这些对象的线程安全,需要由开发 ...
Spring中的Controller ，Service，Dao是不是线程安全的？
作者:myseries cnblogs.com/myseries/p/11729800.html 结论:不是线程安全的 Spring容器中的Bean是否线程安全,容器本身并没有提供Bean的线程安全策 ...

caffeine 线程私有的ReadBuffer实现

caffeine 线程私有的ReadBuffer实现相关推荐

最新文章

热门文章