源码解析
/**
* 尝试获取锁
*/
protected final boolean tryAcquire(int acquires) {
// 获取当前线程
final Thread current = Thread.currentThread();
// 获取锁的状态
int c = getState();
// 没有加锁
if (c == 0) {
/*
* 先判断是否需要排队，如果不需要，才获取锁改变state
* 如果需要，则要进行排队
*/
if (!hasQueuedPredecessors() &&
compareAndSetState(0, acquires)) {
setExclusiveOwnerThread(current);
return true;
}
}
// 如果当前线程已经获取锁了 state+acquires 所以当state > 1 时为重入锁
else if (current == getExclusiveOwnerThread()) {
int nextc = c + acquires;
// nextc < 0 的情况这种情况一般不会发生
if (nextc < 0)
throw new Error("Maximum lock count exceeded");
setState(nextc);
return true;
}
// 返回获取锁失败
return false;
}
