73.如何使用AQS自定义同步器？

AQS的底层使用了模板方法模式，自定义同步器只需要两步：第一，继承AbstractQueuedSynchronizer，第二，重写以下几种方法：

• isHeldExclusively()：该线程是否正在独占资源。只有用到condition才需要去实现它。
• tryAcquire(int)：独占方式，尝试获取资源。
• tryRelease(int)：独占方式，尝试释放资源。
• tryAcquireShared(int)：共享方式，尝试获取资源。负数表示失败，0表示成功，但无剩余可用资源，正数表示成功并且有剩余资源
• tryReleaseShared(int)：共享方式，尝试释放资源

下面举例说明，以独占式的ReentrantLock为例，state初始状态为0，表示未锁定状态。A线程进行lock()时，会调用tryAcquire()独占该锁并将state+1。此后，其他线程再调用tryAcquire()时就会失败，直到A线程unlock()到state=0（即释放锁）为止，其它线程才有机会获取该锁。当然，释放锁之前，A线程自己是可以重复获取此锁的（state会累加），这就是可重入的概念。但要注意，获取多少次就要释放多么次，这样才能保证state是能回到零态的。

再以共享使得CountDownLatch以例，任务分为N个子线程去执行，state也初始化为N（注意N要与线程个数一致）。这N个子线程是并行执行的，每个子线程执行完后countDown()一次，state会CAS减1。等到所有子线程都执行完后(即state=0)，会unpark()主调用线程，然后主调用线程就会从await()函数返回，继续后余动作。

一般来说，自定义同步器要么是独占方法，要么是共享方式，他们也只需实现tryAcquire-tryRelease、tryAcquireShared-tryReleaseShared中的一种即可。但AQS也支持自定义同步器同时实现独占和共享两种方式，如ReentrantReadWriteLock。

这部内容分参考博客：https://www.cnblogs.com/waterystone/p/4920797.html

本站链接：https://www.mianshi.online，如需勘误或投稿，请联系微信：lurenzhang888

---

点击面试手册，获取本站面试手册PDF完整版