并发编程
2021-10-09 11:26:07 57 举报AI智能生成
登录查看完整内容
java并发编程
作者其他创作
大纲/内容
1.通过继承Thread类本身
2.通过实现Runable接口
委派设计模式delegate
FutureTask详解
3.使用callable和Future创建线程
4.使用线程池
1.线程创建
2.线程状态转换
1.线程的生命周期
acquire
release
获取同步状态：acquire
响应中断：acquireInterruptibly
超时获取:tryAcquireNanos
获取锁
释放锁
独占式
acquireShared
releaseShared
共享式
独占锁的获取和释放流程
共享锁的获取和释放流程
独占锁和共享锁在实现上的区别
具体锁的获取和释放流程
同步状态获取与释放
同步器的状态变更
当有线程获取锁了，其他再次获取时需要阻塞，当线程释放锁后，AQS负责唤醒线程
是用来创建锁和其他同步类的基本线程阻塞原语
每个使用LockSupport的线程都会与一个许可关联，如果该许可可用，并且可在进程中使用，则调用park()将会立即返回，否则可能阻塞。如果许可尚不可用，则可以调用 unpark 使其可用
park()、unpark()
LockSupport
线程阻塞和唤醒
FIFO双向队列，AQS依赖它来解决同步状态的管理问题
首节点唤醒，等待队列加入到CLH同步队列的尾部
图片
CLH同步队列
插入和移出队列
原理图
三大关键操作
读写锁
设计思想
核心思想
原理简要总结
AQS
1. AQS
Compare And Swap，整个JUC体系最核心、最基础理论
内存值V、旧的预期值A、要更新的值B，当且仅当内存值V的值等于旧的预期值A时才会将内存值V的值修改为B，否则什么都不干
native中存在四个参数
循环时间太长
只能保证一个共享变量原子操作
版本号
AtomicStampedReference
解决方案
ABA问题
缺陷
2.CAS
2.并发基础
指多个线程按照申请锁的顺序来获取锁
ReentrantLock而言，通过构造函数指定该锁是否是公平锁，默认是非公平锁，Synchronized而言，也是一种非公平锁
1.公平锁/非公平锁
指在同一个线程在外层方法获取锁的时候，在进入内层方法会自动获取锁。
核心就是用计数器记录当前线程获取锁的次数，进去加一，出去减一
2.可重入锁
3.偏向锁/轻量级锁/重量级锁
自旋锁是指尝试获取锁的线程不会立即阻塞，而是采用循环的方式去尝试获取锁，这样的好处是减少线程上下文切换的消耗，缺点是循环会消耗CPU
4.自旋锁
5.独享锁/共享锁
6.互斥锁/读写锁
乐观锁与悲观锁不是指具体的什么类型的锁，而是指看待并发同步的角度。
7.乐观锁/悲观锁
分段锁
1.锁分类
普通同步方法，锁是当前实例对象
静态同步方法，锁是当前类的class对象
同步方法块，锁是括号里面的对象
1. 锁对象
synchronized的锁就是保存在Java对象头中的
Mark Word被设计成一个非固定的数据结构以便在极小的空间内存存储尽量多的数据，它会根据对象的状态复用自己的存储空间
哈希码（HashCode）、GC分代年龄、锁状态标志、线程持有的锁、偏向线程 ID、偏向时间戳
包括
Mark Word（标记字段）
Klass Pointer（类型指针）
包括两部分数据
Java对象头
初始时为NULL表示当前没有任何线程拥有该monitor record，当线程成功拥有该锁后保存线程唯一标识，当锁被释放时又设置为NULL
Owner
monitor
2. 实现机制
为了在无多线程竞争的情况下尽量减少不必要的轻量级锁执行路径
主要尽可能避免不必须要的CAS操作，如果竞争锁失败，则升级为轻量级锁
偏向锁
在没有多线程竞争的前提下，减少传统的重量级锁使用操作系统互斥量产生的性能消耗
通过CAS来获取锁和释放锁
对于绝大部分的锁，在整个生命周期内都是不会存在竞争的
性能依据
在多线程环境下，其运行效率比重量级锁还会慢
缺点
轻量级锁
重量级锁
1.锁的三种状态
原理过程
2.锁升级策略
3. 锁优化
2.synchronized关键字
1.等待可中断
2.可实现公平锁
3.锁可以绑定多个条件
4.Condition实现部分通知，特定通知
高级功能
底层采用AQS实现，通过内部Sync继承AQS
可重入锁，是一种递归无阻塞的同步机制
3.重入锁ReentrantLock(1.5)
读写锁，两把锁：共享锁：读锁、排他锁：写锁
支持公平性、非公平性，可重入和锁降级
锁降级：遵循获取写锁、获取读锁在释放写锁的次序，写锁能够降级成为读锁
4.ReentrantReadWriteLock
Lock 提供条件Condition，对线程的等待、唤醒操作更加详细和灵活
内部维护一个Condition队列。当前线程调用await()方法，将会以当前线程构造成一个节点（Node），并将节点加入到该队列的尾部
5.Condition
死锁必须具备以下四个条件
如何避免线程死锁
6.死锁
1.锁
volatile可见性：对一个volatile的读，总可以看到对这个变量最终的写
volatile原子性：volatile对单个读/写具有原子性（32位Long、Double），但是复合操作除外，例如i++;
特性
内存屏障
实现机制
当写一个volatile变量时，JMM会把该线程对应的本地内存中的共享变量值立即刷新到主内存中
当读一个volatile变量时，JMM会把该线程对应的本地内存设置为无效，直接从主内存中读取共享变量
内存语义
主存、高速缓存（线程私有）缓存一致性
通过在总线加LOCK#锁的方式
通过缓存一致性协议（MESI协议）
操作系统语义
重排序
happens-before
内存模型
volatile
2. volatile关键字
彻底理解ThreadLocal
实现原理
3.ThreadLocal关键字
3.线程安全
1.wait/notify/notifyAll
2.join
4.线程通信
原理图1
原理图2
Java采用
内存共享
消息传递
线程通信机制
为了程序的性能，处理器、编译器都会对程序进行重排序处理
在单线程环境下不能改变程序运行的结果
存在数据依赖关系的不允许重排序
条件
重排序在多线程环境下可能会导致数据不安全
问题
多线程环境下的理论参考模型
为程序提供了极强的内存可见性保证
一个线程中的所有操作必须按照程序的顺序来执行
所有线程都只能看到一个单一的操作执行顺序，不管程序是否同步
每个操作都必须原子执行且立刻对所有线程可见
顺序一致性
JMM中最核心的理论，保证内存可见性
在JMM中，如果一个操作执行的结果需要对另一个操作可见，那么这两个操作之间必须存在happens-before关系。
如果一个操作happens-before另一个操作，那么第一个操作的执行结果将对第二个操作可见，而且第一个操作的执行顺序排在第二个操作之前
两个操作之间存在happens-before关系，并不意味着一定要按照happens-before原则制定的顺序来执行。如果重排序之后的执行结果与按照happens-before关系来执行的结果一致，那么这种重排序并不非法
理论
所有的操作均可以为了优化而被重排序，但是你必须要保证重排序后执行的结果不能被改变
as-if-serial
5.Java内存模型（JMM）
CAS + Synchronized 来保证并发更新的安全，底层采用数组+链表/红黑树的存储结构
key-value键值对
Node
红黑树节点
TreeNode
就相当于一颗红黑树，其构造方法其实就是构造红黑树的过程
TreeBin
辅助节点，用于ConcurrentHashMap扩容操作
控制标识符，用来控制table初始化和扩容操作的
负数代表正在进行初始化或扩容操作
-1代表正在初始化
-N 表示有N-1个线程正在进行扩容操作
正数或0代表hash表还没有被初始化，这个数值表示初始化或下一次进行扩容的大小
含义
sizeCtl
ForwardingNode
重要内部类
ConcurrentHashMap初始化方法
只能有一个线程参与初始化过程，其他线程必须挂起
构造函数不做初始化过程，初始化真正是在put操作触发
sizeCtl < 0 表示正在进行初始化，线程挂起
初始化步骤完成后，设置sizeCtl = 0.75 * n（下一次扩容阈值），表示下一次扩容的大小
步骤
initTable
根据hash值计算节点插入在table的位置，如果该位置为空，则直接插入，否则插入到链表或者树中
真实情况较为复杂
table为null，线程进入初始化步骤，如果有其他线程正在初始化，该线程挂起
如果插入的当前 i 位置 为null，说明该位置是第一次插入，利用CAS插入节点即可，插入成功，则调用addCount判断是否需要扩容。若插入失败，则继续匹配（自旋）
若该节点的hash ==MOVED（-1），表示有线程正在进行扩容，则进入扩容进程中
其余情况就是按照链表或者红黑树结构插入节点，但是这个过程需要加锁（synchronized）
put
table ==null ；return null
从链表/红黑树节点获取
get
多线程扩容
构建一个nextTable，其大小为原来大小的两倍，这个步骤是在单线程环境下完成的
将原来table里面的内容复制到nextTable中，这个步骤是允许多线程操作
扩容
所在链表的元素个数达到了阈值 8，则将链表转换为红黑树
红黑树算法
链表转换为红黑树过程
重要操作
1.8 与 1.7的区别
重要参数
JDK1.8中 ConcurrentHashMap 中的CAS 和 synchronized是如何使用的
ConcurrentHashMap
基于链接节点的无边界的线程安全队列，采用FIFO原则对元素进行排序，内部采用CAS算法实现
在入队的最后一个元素的next为null
队列中所有未删除的节点的item都不能为null且都能从head节点遍历到
对于要删除的节点，不是直接将其设置为null，而是先将其item域设置为null（迭代器会跳过item为null的节点）
允许head和tail更新滞后。这是什么意思呢？意思就说是head、tail不总是指向第一个元素和最后一个元素（后面阐述）
不变性
head的不变性和可变性
tail的不变性和可变性
精妙之处：利用CAS来完成数据操作，同时允许队列的不一致性，弱一致性表现淋漓尽致
ConcurrentLinkedQueue
第三种key-value数据结构：SkipList（跳表）
平衡二叉树结构
Skip list让已排序的数据分布在多层链表中，以0-1随机数决定一个数据的向上攀升与否，通过“空间来换取时间”的一个算法， 在每个节点中增加了向前的指针，在插入、删除、查找时可以忽略一些不可能涉及到的结点，从而提高了效率
由很多层结构组成，level是通过一定的概率随机产生的
每一层都是一个有序的链表，默认是升序，也可以根据创建映射时所提供的Comparator进行排序，具体取决于使用的构造方法
最底层(Level 1)的链表包含所有元素
如果一个元素出现在Level i 的链表中，则它在Level i 之下的链表也都会出
每个节点包含两个指针，一个指向同一链表中的下一个元素，一个指向下面一层的元素
查找、删除、添加
SkipList
ConcurrentSkipListMap
内部采用ConcurrentSkipListMap实现
ConcurrentSkipListSet
什么是CopyOnWrite容器
数据一致性问题
CopyOnWriteArrayList
Collections.synchronizedList
6.Java并发集合
类结构
线程池原理剖析
静态工厂类，提供了Executor、ExecutorService、ScheduledExecutorService、ThreadFactory 、Callable 等类的静态工厂方法
Executors
线程池中核心线程的数量
corePoolSize
线程池中允许的最大线程数
maximumPoolSize
线程空闲的时间
keepAliveTime
keepAliveTime的单位
unit
用来保存等待执行的任务的阻塞队列
ArrayBlockingQueue
LinkedBlockingQueue
SynchronousQueue
PriorityBlockingQueue
使用的阻塞队列
workQueue
用于设置创建线程的工厂
DefaultThreadFactory
threadFactory
RejectedExecutionHandler，线程池的拒绝策略
AbortPolicy：丢弃任务并抛出RejectedExecutionException异常。线程池默认的拒绝策略
CallerRunsPolicy：由调用线程处理该任务
DiscardOldestPolicy：丢弃队列最前面的任务，然后重新尝试执行任务（重复此过程）
DiscardPolicy：也是丢弃任务，但是不抛出异常。
分类
handler
参数含义
可重用固定线程数的线程池
corePoolSize和maximumPoolSize一致
使用“无界”队列LinkedBlockingQueue
maximumPoolSize、keepAliveTime、RejectedExecutionHandler 无效
分析
newFixedThreadPool
使用单个worker线程的Executor
corePoolSize和maximumPoolSize被设置为1
SynchronousQueue作为WorkerQueue
newSingleThreadExecutor
会根据需要创建新线程的线程池
corePoolSize被设置为0
maximumPoolSize被设置为Integer.MAX_VALUE
如果主线程提交任务的速度高于maximumPool中线程处理任务的速度时，CachedThreadPool会不断创建新线程 ，可能会耗尽CPU和内存资源
使用LinkedBlockingQueue作为workerQueue
newCachedThreadPool
线程池分类
Executor.execute()
ExecutorService.submit()
任务提交
执行流程
任务执行
ThreadPoolExecutor
继承自ThreadPoolExecutor
给定的延迟之后运行任务，或者定期执行任务
内部使用DelayQueue来实现 ，会把调度的任务放入DelayQueue中。DelayQueue内部封装PriorityQueue，这个PriorityQueue会对队列中的ScheduledFutureTask进行排序
ScheduledThreadPoolExecutor
Executor
异步计算
执行任务的取消
查询任务是否完成
获取任务的执行结果
提供操作
Future
实现Runnable，Future接口，既可以作为Runnable被执行，也可以作为Future得到Callable的返回值
内部基于AQS实现
FutureTask
通过重复利用已创建的线程降低线程创建和销毁造成的消耗
降低资源消耗
当任务到达时，任务可以不需要等到线程创建就能立即执行
提高响应速度
进行统一分配、调优和监控
提高线程的可管理性
好处
CPU密集型任务应配置尽可能小的线程，如配置CPU个数+1的线程数.
CPU密集
IO密集型任务应配置尽可能多的线程，因为IO操作不占用CPU，不要让CPU闲下来，应加大线程数量，如配置两倍CPU个数+1.
IO密集
混合型的任务，如果可以拆分，拆分成IO密集型和CPU密集型分别处理，前提是两者运行的时间是差不多的，如果处理时间相差很大，则没必要拆分了。
混合型的任务
最佳线程数目 = （（线程等待时间+线程CPU时间）/线程CPU时间 ）* CPU数目
三种模型
线程池调优
线程池监控
数据库线程池
JDK 实现线程池功能比较完善，但是比较适合运行 CPU 密集型任务，不适合 IO 密集型的任务。对于 IO 密集型任务可以间接通过设置线程池参数方式做到。
https://zhuanlan.zhihu.com/p/94679167
原生线程池这么强大，Tomcat 为何还需扩展线程池？
线程池
7.线程池
它允许一组线程互相等待，直到到达某个公共屏障点 (common barrier point)
通俗讲：让一组线程到达一个屏障时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续干活
底层采用ReentrantLock + Condition实现
多线程结果合并的操作，用于多线程计算数据，最后合并计算结果的应用场景
应用场景
CyclicBarrier（屏障）
在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待
用给定的计数 初始化 CountDownLatch。由于调用了 countDown() 方法，所以在当前计数到达零之前，await 方法会一直受阻塞。之后，会释放所有等待的线程，await 的所有后续调用都将立即返回。这种现象只出现一次——计数无法被重置。如果需要重置计数，请考虑使用 CyclicBarrier。
CountDownLatch的作用是允许1或N个线程等待其他线程完成执行；而CyclicBarrier则是允许N个线程相互等待
CountDownLatch的计数器无法被重置；CyclicBarrier的计数器可以被重置后使用，因此它被称为是循环的barrier
与CyclicBarrier区别
内部采用共享锁来实现
CountDownLatch（倒计数器-人全走了再吃饭）
一个控制访问多个共享资源的计数器
信号量
从概念上讲，信号量维护了一个许可集。如有必要，在许可可用前会阻塞每一个 acquire()，然后再获取该许可。每个 release() 添加一个许可，从而可能释放一个正在阻塞的获取者。但是，不使用实际的许可对象，Semaphore 只对可用许可的号码进行计数，并采取相应的行动
信号量Semaphore是一个非负整数（>=1）。当一个线程想要访问某个共享资源时，它必须要先获取Semaphore，当Semaphore >0时，获取该资源并使Semaphore – 1。如果Semaphore值 = 0，则表示全部的共享资源已经被其他线程全部占用，线程必须要等待其他线程释放资源。当线程释放资源时，Semaphore则+1
通常用于限制可以访问某些资源（物理或逻辑的）的线程数目
内部采用共享锁实现
Semaphore（计数信号量-房间里任何时候只能有指定的人数（比如5人）可以吃饭）
可以在对中对元素进行配对和交换的线程的同步点
允许在并发任务之间交换数据。具体来说，Exchanger类允许在两个线程之间定义同步点。当两个线程都到达同步点时，他们交换数据结构，因此第一个线程的数据结构进入到第二个线程中，第二个线程的数据结构进入到第一个线程中
exchanger
原子类
1. 并发工具类
原理CAS
用于通过原子的方式更新基本类型
原子更新布尔类型
AtomicBoolean
原子更新整型
AtomicInteger
原子更新长整型
AtomicLong
基本类型类
通过原子的方式更新数组里的某个元素
原子更新整型数组里的元素
AtomicIntegerArray
原子更新长整型数组里的元素
AtomicLongArray
原子更新引用类型数组里的元素
AtomicReferenceArray
数组
如果要原子的更新多个变量，就需要使用这个原子更新引用类型提供的类
原子更新引用类型
AtomicReference
原子更新引用类型里的字段
AtomicReferenceFieldUpdater
原子更新带有标记位的引用类型
AtomicMarkableReference
引用类型
如果我们只需要某个类里的某个字段，那么就需要使用原子更新字段类
原子更新整型的字段的更新器
AtomicIntegerFieldUpdater
原子更新长整型字段的更新器
AtomicLongFieldUpdater
原子更新带有版本号的引用类型
字段类
2. 原子类
一个由数组实现的FIFO有界阻塞队列
ArrayBlockingQueue有界且固定，在构造函数时确认大小，确认后不支持改变
在多线程环境下不保证“公平性”
ReentrantLock
Condition
实现
支持优先级的无界阻塞队列
默认情况下元素采用自然顺序升序排序，可以通过指定Comparator来对元素进行排序
父节点的键值总是大于或等于任何一个子节点的键值
最大堆
父节点的键值总是小于或等于任何一个子节点的键值
最小堆
添加操作则是不断“上冒”，而删除操作则是不断“下掉”
二叉堆
ReentrantLock + Condition
支持延时获取元素的无界阻塞队列
缓存：清掉缓存中超时的缓存数据
任务超时处理
应用
用来标记那些应该在给定延迟时间之后执行的对象
该接口要求实现它的实现类必须定义一个compareTo 方法，该方法提供与此接口的 getDelay 方法一致的排序。
Delayed接口
根据Delay时间排序的优先级队列：PriorityQueue
DelayQueue
是一个内部只能包含一个元素的队列
插入元素到队列的线程被阻塞，直到另一个线程从队列中获取了队列中存储的元素。同样，如果线程尝试获取元素并且当前不存在任何元素，则该线程将被阻塞，直到线程将元素插入队列。
难搞懂，与Exchanger 有一拼
链表组成的的无界阻塞队列
相当于ConcurrentLinkedQueue、SynchronousQueue (公平模式下)、无界的LinkedBlockingQueues等的超集
有就直接拿走，没有就占着这个位置直到拿到或者超时或者中断
预占模式
LinkedTransferQueue
由链表组成的双向阻塞队列
容量可选，在初始化时可以设置容量防止其过度膨胀，如果不设置，默认容量大小为Integer.MAX_VALUE
“工作窃取”模式
运用
LinkedBlockingDeque
阻塞队列
3. 阻塞队列
一个用于并行执行任务的框架， 是一个把大任务分割成若干个小任务，最终汇总每个小任务结果后得到大任务结果的框架
分治
fork分解任务，join收集数据
某个线程从其他队列里窃取任务来执行
执行块的线程帮助执行慢的线程执行任务，提升整个任务效率
队列要采用双向队列
工作窃取
执行任务的线程池
ForkJoinPool
表示任务，用于ForkJoinPool的任务抽象
ForkJoinTask
执行任务的工作线程
ForkJoinWorkerThread
核心类
4. Fork/Join
8.并发工具类
并发编程
0 条评论
回复 删除
下一页
