摘要:耐心看完的你或多或少会有收获并发的核心就是包,而的核心是抽象队列同步器,简称,一些锁啊信号量啊循环屏障啊都是基于。
耐心看完的你或多或少会有收获!
Java并发的核心就是 java.util.concurrent 包,而 j.u.c 的核心是AbstractQueuedSynchronizer抽象队列同步器,简称 AQS,一些锁啊!信号量啊!循环屏障啊!都是基于AQS。而 AQS 又是基于Unsafe的一系列compareAndSwap,所以理解了这块,并发不再是问题!
希望你已经了解了 Java内存模型
何为 CAS先解释下何为compareAndSwap,就拿AtomicInteger来举例了:
// 实际操作的值 private volatile int value; // value 的偏移量 因为 int 是32位,知道首部地址就可以了 private static final long valueOffset; // 静态初始化块,通过虚拟机提供的接口,获得 valueOffset = 12 // 不论你实例化多少个 AtomicInteger 对象,这些对象尽管指向不同的堆内存,但是结构都是一样的 // 所以初始化一次就好了 static { try { valueOffset = unsafe.objectFieldOffset (AtomicInteger.class.getDeclaredField("value")); } catch (Exception ex) { throw new Error(ex); } } // 只是个封装方法,起作用的代码并不在这 // 值得注意的是显式的 this 和第三个参数 1 public final int getAndIncrement() { return unsafe.getAndAddInt(this, valueOffset, 1); } // 以下是 Unsafe 类 可以直接访问内存地址,类似指针,所以不安全 // o 就是 getAndIncrement()传入的 this,也就是 AtomicInteger 实例对象 // offset 内存首部偏移量 // delta 就是那个 1 // 应该是希腊字母 δ /"deltə/ delta 变化量,化学反应中的加热,屈光度,一元二次方程中的判别式 // 佩服 public final int getAndAddInt(Object o, long offset, int delta) { int v; do { v = getIntVolatile(o, offset); } while (!compareAndSwapInt(o, offset, v, v + delta)); return v; } // 从堆内存获取最新的 value // 如果不明白,可以先了解下 JMM 和 volatile public native int getIntVolatile(Object o, long offset); // expected 就是这个 v = getIntVolatile(o, offset); // 意思就是,我给你这个最新的 value,它要是现在 在内存中还是这个值 那你就返回 true,并且把这块内存上值更新为 x // 不然的话,我就一直 while (!compareAndSwapInt(o, offset, v, v + delta)); // 相当于自旋锁 活锁,不要被高大上的术语吓到 就是活的循环,不会像死锁那样线程 hang 住 public final native boolean compareAndSwapInt(Object o, long offset, int expected, int x);何为 Lock
知道了CAS就可以进一步的说说ReentrantLock, 如果不曾了解Java对象结构,建议先了解下 Java 对象的内存结构
AQS的几个子类,由于方法和功能不一,在同步处理的细节上可能不一样。但是,原理都是一样的,离不开上述的CAS
// 我先简单解释一下 synchronized 工作原理 首先它含有 monitorenter 和 monitorexit 两条指令 // Java 中的每个对象都有自己的 Monitor(由HotSpot c++ 实现) // 当某个线程进入加锁的代码(实际上应该是拿到被加锁的对象在内存的引用地址) // 会执行 monitorenter 然后将 monitor 置为1,当其它线程访问该内存时,发现 monitor 不为 0 // 所以其它线程无法获得 monitor,直到占有 monitor 的线程执行 monitorexit 退出将 monitor 减 1 // 如果占有 monitor 的线程重复进入,monitor 是可以一直累加的(可重入锁,例如通过递归或方法互调) // 了解了 synchronized 基本的工作原理,就会明白为什么会有诸如 nonfairTryAcquire(1) release(1) 的方法 // 这是 AbstractQueuedSynchronizer 类中的字段 // 因为 ReentrantLock 中的内部类 Sync 继承于 AQS // The synchronization state private volatile int state; // tryLock why ? // 因为不同于 synchronized 的悲观(我才不管你是不是并发,多线程,声明了,我就加锁) // 所以 ReentrantLock 我先 try 一 try 吧!万一不是多线程并发呢!
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/74934.html
摘要:线程池的作用降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的资源浪费。而高位的部分,位表示线程池的状态。当线程池中的线程数达到后,就会把到达的任务放到中去线程池的最大长度。默认情况下,只有当线程池中的线程数大于时,才起作用。 线程池的作用 降低资源消耗。通过重复利用已创建的线程降低线程创建和销毁造成的资源浪费。 提高响应速度。当任务到达时,不需要等到线程创建就能立即执行...
摘要:在线程处理任务期间,其它线程要么循环访问,要么一直阻塞等着线程唤醒,再不济就真的如我所说,放弃锁的竞争,去处理别的任务。写锁的话,独占写计数,排除一切其他线程。 回顾 在上一篇 Java并发核心浅谈 我们大概了解到了Lock和synchronized的共同点,再简单总结下: Lock主要是自定义一个 counter,从而利用CAS对其实现原子操作,而synchronized是c++...
摘要:比如需要用多线程或分布式集群统计一堆用户的相关统计值,由于用户的统计值是共享数据,因此需要保证线程安全。如果类是无状态的,那它永远是线程安全的。参考探索并发编程二写线程安全的代码 线程安全类 保证类线程安全的措施: 不共享线程间的变量; 设置属性变量为不可变变量; 每个共享的可变变量都使用一个确定的锁保护; 保证线程安全的思路: 1. 通过架构设计 通过上层的架构设计和业务分析来避...
摘要:基础问题的的性能及原理之区别详解备忘笔记深入理解流水线抽象关键字修饰符知识点总结必看篇中的关键字解析回调机制解读抽象类与三大特征时间和时间戳的相互转换为什么要使用内部类对象锁和类锁的区别,,优缺点及比较提高篇八详解内部类单例模式和 Java基础问题 String的+的性能及原理 java之yield(),sleep(),wait()区别详解-备忘笔记 深入理解Java Stream流水...
阅读 1759·2021-11-18 13:20
阅读 1142·2021-10-11 10:59
阅读 2988·2021-08-24 10:01
阅读 3501·2019-08-29 14:21
阅读 3352·2019-08-29 14:15
阅读 3515·2019-08-26 12:23
阅读 3343·2019-08-26 11:46
阅读 3345·2019-08-26 11:35