Java并发之AQS原理解读（一）

AQS

抽象队列同步器AQS是java.util.concurrent.locks包下比较核心的类之一，包括AbstractQueuedSynchronizer和AbstractQueuedLongSynchronizer两个类，两者分别采用int和long来定义同步状态state。

AQS是Java中一些常用锁容器的父类，提供了一套模板方法供子类自定义实现，主要职责在于：

• 同步状态state的维护
• 等待队列Node维护阻塞线程

同步状态state

state表示同步状态，不同子类使用它来表示不同含义，举例而言：

• ReentranLock使用state表示持有锁的线程重入次数。当state大于0时，说明锁已被占用，则当前线程添加到等待队列
• CountDownLatch使用state表示门栓计数。当计数大于0时，线程添加到等待队列；当线程等于0时，唤醒队列中线程
• Semaphore使用state表示可用的信号量。当state等于0时，表示没有可用的信号量，线程添加到等待队列；线程执行完后，释放信号量，即state+1
  
  

公共方法
通过三个不可重写方法操作state，修改通过CAS保证线程安全，子类可使用这三个方法：

// volatile 保证线程可见
private volatile int state;

protected final int getState() {
	return state;
}

// 用于初始化场景
protected final void setState(int newState) {
	state = newState;
}

// 用于并发修改
protected final boolean compareAndSetState(int expect, int update) {
	// unsafe#cas to update state
	return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}

子类实现的方法

// 尝试以独占模式获取操作，需要子类实现允许以独占模式获取它
protected boolean tryAcquire(int arg) {
	throw new UnsupportedOperationException();
}
// 尝试以独占的方式释放
protected boolean tryRelease(int arg) {
	throw new UnsupportedOperationException();
}

// 尝试以共享的方式获取操作
protected int tryAcquireShared(int arg) {
	throw new UnsupportedOperationException();
}
// 尝试以共享的方式释放
protected boolean tryReleaseShared(int arg) {
	throw new UnsupportedOperationException();
}
// 判断调用线程是否是独占锁的持有者
protected boolean isHeldExclusively() {
	throw new UnsupportedOperationException();
}

子类不需要实现上面所有方法，可以选择独占或者共享的方式实现。
独占锁：

• ReentranLock
• ReentranWriteReadLock.WriteLock

共享锁：

• CountDownLatch
• CyclicBarrier
• Semaphore
• ReentranWriteReadLock.ReadLock

下一篇： Java并发之AQS原理解读（二）

Java并发之AQS原理解读（一）

原文：https://www.cnblogs.com/flowers-bloom/p/15144425.html