企业网站建设方案文档,百度ai搜索引擎,网络营销促销方案,阿里云做的网站怎么备份ReentrantLock源码解读
在讲ReentrantLock之前我们先看一下Lock接口里的方法
Lock接口中的方法
lock()方法
void lock(); //直接加锁,如果加锁失败什么也不返回lockInterruptibly()方法
void lockInterruptibly() throws InterruptedException;lockInterruptibly()方法能够…ReentrantLock源码解读
在讲ReentrantLock之前我们先看一下Lock接口里的方法
Lock接口中的方法
lock()方法
void lock(); //直接加锁,如果加锁失败什么也不返回lockInterruptibly()方法
void lockInterruptibly() throws InterruptedException;lockInterruptibly()方法能够中断等待获取锁的线程。当两个线程同时通过lock.lockInterruptibly()获取某个锁时假若此时线程A获取到了锁而线程B只有等待那么对线程B调用threadB.interrupt()方法能够中断线程B的等待过程。
tryLock()
boolean tryLock(); //直接加锁,如果加锁失败返回falsetryLock(long time, TimeUnit unit)
boolean tryLock(long time, TimeUnit unit) throws InterruptedException; // 尝试获取锁如果没获取到锁就等待一段时间这段时间内还没获取到锁就返回falseunlock()方法
void unlock();//释放锁newCondition()
Condition newCondition();// 条件锁以上就是Lock接口中的方法接下来我们看一下ReentrantLock的实现代码。
ReentrantLock的内部类
首先是ReentrantLock的三个内部类Sync、NonfairSync、FairSync其中NonfairSync类和FairSync类是继承Sync类
Sync类
首先Sync是一个静态的抽象类下面我们看一下它的内部方法。
lock()
abstract void lock(); //抽象方法由子类实现nonfairTryAcquire()
final boolean nonfairTryAcquire(int acquires) {final Thread current Thread.currentThread();int c getState();if (c 0) {//判断当前是否有线程持有锁if (compareAndSetState(0, acquires)) {//使用CAS尝试加锁setExclusiveOwnerThread(current);return true;}}else if (current getExclusiveOwnerThread()) {//判断当前持有锁的线程是否是自己int nextc c acquires;if (nextc 0) // overflowthrow new Error(Maximum lock count exceeded);setState(nextc); //锁重入了修改state的值return true;}return false;
}tryRelease()
释放锁的方法
protected final boolean tryRelease(int releases) {int c getState() - releases;if (Thread.currentThread() ! getExclusiveOwnerThread())throw new IllegalMonitorStateException();boolean free false;if (c 0) {free true;setExclusiveOwnerThread(null);}setState(c);return free;
}isHeldExclusively()
判断锁是否是当前线程持有
protected final boolean isHeldExclusively() {// While we must in general read state before owner,// we dont need to do so to check if current thread is ownerreturn getExclusiveOwnerThread() Thread.currentThread();
}newCondition()
// 条件锁
final ConditionObject newCondition() {return new ConditionObject();
}getOwner()
返回当前持有锁的线程如果没有则返回null
final Thread getOwner() {return getState() 0 ? null : getExclusiveOwnerThread();
}getHoldCount()
当前线程持有此锁的次数如果当前线程不持有此锁则为零
final int getHoldCount() {return isHeldExclusively() ? getState() : 0;
}NonfairSync类
NonfairSync是非公平锁的实现类继承了Sync类。
lock()
加锁方法因为是非公平锁所以在加锁的时候会先去尝试加锁如果加锁失败则调用acquire()方法放入队列排队
final void lock() {if (compareAndSetState(0, 1))setExclusiveOwnerThread(Thread.currentThread());elseacquire(1);
}tryAcquire()
这里是调用父类的方法nonfairTryAcquire
protected final boolean tryAcquire(int acquires) {return nonfairTryAcquire(acquires);
}FairSync类
FairSync公平锁的实现类
lock()
加锁方法
final void lock() {acquire(1);//调用父类的方法加锁
}tryAcquire()
protected final boolean tryAcquire(int acquires) {final Thread current Thread.currentThread();//获取当前线程int c getState(); //获取锁标志位的值if (c 0) {//判断锁是否被其他线程占用if (!hasQueuedPredecessors() compareAndSetState(0, acquires)) {setExclusiveOwnerThread(current);return true;}}else if (current getExclusiveOwnerThread()) {//判断当前持有锁的线程是否是自己int nextc c acquires;if (nextc 0)throw new Error(Maximum lock count exceeded);setState(nextc);return true;}return false;}
}以上就是ReentrantLock的内部类了接下来看一下构造方法
ReentrantLock的构造方法
无参构造方法
无参构造方法默认使用非公平锁
public ReentrantLock() {sync new NonfairSync();
}有参构造
传入参数为true时是公平锁false是非公平锁
public ReentrantLock(boolean fair) {sync fair ? new FairSync() : new NonfairSync();
}ReentrantLock的其他方法
其他方法的调用主要主要看ReentrantLock使用的是公平锁还是非公平锁这里就不一一介绍了关于ReentrantLock的锁的实现还涉及到了AbstractQueuedSynchronizer、AbstractOwnableSynchronizer这两个类这些我们后面再继续分析。
