扫码关注微信公众号

回复“面试手册”,获取本站PDF版

回复“简历”,获取高质量简历模板

回复“加群”,加入程序员交流群

回复“电子书”,获取程序员类电子书

当前位置: Java > Java并发高频面试题 > 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-tryReleasetryAcquireShared-tryReleaseShared中的一种即可。但AQS也支持自定义同步器同时实现独占和共享两种方式,如ReentrantReadWriteLock

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


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