JUC并发包是jdk提供的一系列关于并发框架的jar包,最基本的有Lock和Condition,对应sychronized和wait¬ify的功能,其核心是AQS抽象队列同步器。
AQS
AQS抽象队列同步器维护着一个FIFO阻塞同步队列,还有一个内部类ConditionObject,一个FIFO等待队列,它们的基本数据结构都是一个Node类。Node主要有prev,next,nextWaiter,waitStatus这些属性。此外还有一个state记录锁次数,owner记录当前获取锁的线程。下面以Reentrantlock来分析具体过程。
lock()
首先会使用cas操作尝试更新state=1,若成功表明未有线程获取锁,设置当前线程为owner,线程继续执行。若更新失败表示已有其他线程获取到锁,将当前线程包装为一个Node,并cas设置waitStatus为-1(Node.Singal)放入AQS队列尾部(若head为空,则新建一个Node节点作为head),设置prev和next。然后自旋对这个Node尝试获取锁,成功则将此Node设为head,前一个节点的next设为null帮助gc回收,失败则park当前线程使之阻塞。
unlock()
使state减1,若state为0表明锁已全部释放完。获取AQS结点中的头结点的下一节点,唤醒其中线程,则唤醒此时被park的线程继续自旋获取到锁。如果是共享模式则在自旋设置head之后多执行了一步操作,继续唤醒后续共享模式结点中的线程。
await()
必须在当前线程获取锁时才能执行,首先把当前线程构成一个Node,设置waitStatus为-2(Node.CONDITION)并放入ConditionObject队列尾部。然后对当前线程完全释放锁,唤醒AQS中的头部线程,随后park当前线程。
singal()&singalAll()
取ConditionObject队列首部节点,并把它从队列中移除,CAS将Node的waitStatus从CONDITION置为0,随后放入AQS队列的尾部,再设置waitStatus从CONDITION置为-1,unpark唤醒这个线程。
CAS操作
CAS比较交换是一种乐观锁机制,其过程是取当前值和预期值进行比较,若一致,则将更新值作为最新值,不一致则操作失败,它是一种cpu指令级别的原子操作,且是直接根据内存中的地址来做对比更新。
park&unpark
park&unpark底层原理是获取一个许可&给予一个许可,在jvm中每个线程有一个Parker实例,其中有个_counter变量来记录是否有许可。
1.unpark时先更新_counter为1,并判断之前的_counter小于1;
如果小于1,则去唤醒阻塞的线程,若有线程被唤醒然后使_counter为0;
如果给定线程没有启动start,则该操作没有任何效果.
2.park,则会检测_counter是否大于0;
如果大于0则将_counter变成0,线程继续执行,否则堵塞线程。
3.线程被park后阻塞时,如果被中断也会被唤醒。
JUC并发工具包
1.Semaphore 信号量是一类经典的同步工具。信号量通常用来限制线程可以同时访问的(物理或逻辑)资源数量。
2.CountDownLatch闭锁 一种非常简单、但很常用的同步辅助类。其作用是在完成一组正在其他线程中执行的操作之前,允许一个或多个线程一直阻塞。CountDownLatch闭锁状态包括一个计数器,该计数器被初始化为一个正数,表示需要等待的事件数量。countDown方法将递减计数器,表示有一个事件已经发生了,而await方法等待计数器到达零,这表示所有需要的事件都已经发生。如果计数器的值为非零,那么await会一直阻塞直到计数器为零,或者等待中的线程中断,或者等待超时。
3.CyclicBarrier栅栏类似于闭锁,它能阻塞线程直到某个事件发生。当线程到达栅栏位置时,将调用await方法,这个方法将阻塞直到所有线程都到达阻塞位置。如果所有线程都到达了栅栏的位置,那么栅栏将打开,此时所有线程都将被释放,而栅栏将被重置以便下次使用。如果对await的调用超时,或者await阻塞的线程被中断,那么栅栏就被认为是打破了,所有阻塞的await调用都将终止并抛出BrokenBarrierException。如果成功地通过栅栏,那么await将为每个线程返回一个唯一的到达索引号,我们可以利用这些索引来“选举”产生一个领导线程,并在下一次迭代中由该领导线程执行一些特殊的工作。
栅栏与闭锁的关键区别在于:所有线程必须同时到达栅栏位置,才能继续执行。而且闭锁只能使用一次,而栅栏可以重复循环使用。
4.JDK1.7中的Phaser一种可重用的同步屏障,功能上类似于CyclicBarrier和CountDownLatch,但使用上更为灵活。CountDownLatch和CyclicBarrier都是只适用于固定数量的参与者,Phaser适用于可变数目的屏障。
5.JDK1.8中的StampedLock,优化了之前的读写锁ReentrantReadWriteLock。读写锁特点是读-读不互斥(Node设置为共享模式),读-写互斥,写-写互斥,本质上来说都是悲观锁。StampedLock在将读锁优化成了一种乐观锁机制,而对于读-写的情况,在读的时候会判断是否有写操作,有则再读一次。