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在将读锁优化成了一种乐观锁机制，而对于读-写的情况，在读的时候会判断是否有写操作，有则再读一次。
网友评论