对于ReentrantLock来说,其执行逻辑如下所示:
- 尝试获取对象的锁,如果获取不到(意味着已经有其他线程持有了锁,并且尚未释放),那么它就会进入到AQS的阻塞队列当中。
- 如果获取到,那么根据锁是公平锁还是非公平锁来进行不同的处理
2.1 如果是公平锁,那么线程会直接放置到AQS阻塞队列的末尾
2.2 如果是非公平锁,那么线程会首先尝试进行CAS计算,如果成功,则直接获取到锁;
如果失败,则与公平锁的处理方式一致,被放到阻塞队列末尾 - 当锁被释放时(调用了unlock方法),那么底层会调用release方法对state成员变量值进行减一操作,如果减一后,state值不为0,
那么release操作就执行完毕;如果减一操作后,state值为0,则调用LockSupport的unpark方法唤醒该线程后的等待队列中的第一个
后继线程(pthread_mutex_unlock),将其唤醒,使之能够获取到对象的锁(release时,对于公平锁与非公平锁的处理逻辑是一致的);
之所以调用release方法后state值可能不为零,原因在于ReentrantLock是可重入锁,表示线程可以多次调用lock方法,
导致每调用一次,state值都会加一。
对于ReentrantLock来说,所谓的上锁,本质上就是对AQS中的state成员变量的操作:对该成员变量+1,表示上锁;对该成员变量-1,表示释放锁。
关于ReentrantReadWriteLock的操作逻辑:
读锁:
- 在获取读锁时,会尝试判断当前对象是否拥有了写锁,如果已经拥有,则直接失败。
- 如果没有写锁,就表示当前对象没有排他锁,则当前线程会尝试给对象加锁
- 如果当前线程已经持有了该对象的锁,那么直接将读锁数量加1
写锁:
- 在获取写锁时,会尝试判断当前对象是否拥有了锁(读锁与写锁),如果已经拥有且持有的线程并非当前线程,直接失败。
- 如果当前对象没有被加锁,那么写锁就会为为当前对象上锁,并且将写锁的个数加1.
- 将当前对象的排他锁线程持有者设为自己