java源码-Semaphore源码分析

Semaphore内部Sync对象同样也是继承AQS,跟Reentrant一样有公平锁跟非公平锁区分,但是Semaphore是基于共享锁开发,Reentrant是基于独占锁开发。主要就是初始化Semaphore时候设置一个指定state值,
当线程执行需要调用
acquire()获取锁,执行完成需要手调用relase()释放锁,当获取凭证达到设置初始的峰值,则会加入CLH阻塞队列等下唤醒。下面来分析一下具体代码。
Semaphore如何获取锁的呢,我们知道共享锁的tryAcquireShare()返回正数代表获取锁成功,负数跟0代表获取失败加入CLh队列,我们先分析下
Semaphore如何获取锁,
如果是公平锁,直接判断是否有前驱节点,有的话直接加入到队列中。非公平锁直接竞争一次锁,然后返回竞争成功后的state值。
《java源码-Semaphore源码分析》

《java源码-Semaphore源码分析》

再看下是如何唤醒CLH阻塞队列的,首先调用relase(1)再调用relaseShared(1)方法,tryRelaseShared(1)方法将state+relases通过cas设置成功然后返回true,开始唤醒等待队列,doRelaseShared()方法在CountDownLatch分析过

传播唤醒next节点,直到全部唤醒或者被阻塞。

《java源码-Semaphore源码分析》

《java源码-Semaphore源码分析》

 



 
    原文作者:java源码分析
    原文地址: https://www.cnblogs.com/1ssqq1lxr/p/9522377.html
    本文转自网络文章,转载此文章仅为分享知识,如有侵权,请联系博主进行删除。
点赞