标签：time   risc   state   out   void   vat   iter   targe   操作   

AQS

AQS(AbstractQueuedSynchronizer)是 java.util.concurrent的基础。J.U.C中宣传的封装良好的同步工具类Semaphore、CountDownLatch、ReentrantLock、ReentrantReadWriteLock、FutureTask等虽然各自都有不同特征，但是简单看一下源码，每个类内部都包含一个如下的内部类定义：

abstract static class Sync extends AbstractQueuedSynchronizer

同时每个类内部都包含有这样一个属性，连属性名都一样！注释已经暗示了，该类的同步机制正是通过这个AQS的子类来完成的。不得不感叹：“每个强大的同步工具类，内心都有一把同样的锁！”

/** All mechanics via AbstractQueuedSynchronizer subclass */

private final Sync sync;

几种同步类提供的功能其实都是委托sync来完成。有些是部分功能，有些则是全部功能。

AQS类中三个重要的属性：

private transient volatile AbstractQueuedSynchronizer.Node head;
private transient volatile AbstractQueuedSynchronizer.Node tail;
private volatile int state;

Node类型的head和tail是一个FIFO的wait queue；一个int类型的状态位state。到这里也能猜到AQS对外呈现（或者说声明）的主要行为就是由一个状态位和一个有序队列来配合完成。 最简单的读一下主要的四个方法：

//获取排他锁
public final void acquire(int arg) {

     if (!tryAcquire(arg) &&

        acquireQueued(addWaiter(Node.EXCLUSIVE), arg))

         selfInterrupt();

 }

//释放排他锁
public final boolean release(int arg) {

 if (tryRelease(arg)) {

  Node h = head;

 if (h != null && h.waitStatus != 0)

 unparkSuccessor(h);

 return true;

 }

return false;

 }

//获取共享锁
public final void acquireShared(int arg) {

       if (tryAcquireShared(arg) < 0)

           doAcquireShared(arg);

}

//释放共享锁
public final boolean releaseShared(int arg) {

        if (tryReleaseShared(arg)) {

            doReleaseShared();

            return true;

        }

        return false;

}

ReentrantLock

ReentrantLock对外的主要方法是lock()，tryLock()和unlock()方法，当然还有其他变种的lockInterruptibly()、tryLock(long timeout, TimeUnit unit)等。

lock()方法的功能是获取锁。如果没有线程使用则立即返回，并设置state为1；如果当前线程已经占有锁，则state加1；如果其他线程占有锁，则当前线程不可用，等待。

public void lock() {
    sync.lock();
}

tryLock()的功能是：如果锁可用，则获取锁，并立即返回值 true。如果锁不可用，立即返回值 false。

public boolean tryLock() {
      return sync.nonfairTryAcquire(1);
  }

unlock()的功能是尝试释放锁，如果当前线程占有锁则count减一，如果count为0则释放锁。若占有线程不是当前线程，则抛异常。

public void unlock() {
    sync.release(1);
}

可以看到也是借助Sync来完成，我们下面详细看下Sync是如何实现这些”规定”的需求的。ReentrantLock的构造函数告诉我们，其支持公平和非公平两种锁机制。

public ReentrantLock(boolean fair) {
    sync = (fair)? new FairSync() : new NonfairSync();
}    

在该类中对应定了两种FairSync和NonfairSync两种同步器，都继承者AQS。可以看到对应执行的是lock、release、和Sync的nonfairTryAcquire。从前面AQS源码知道release是在父类AQS中定义的方法，lock和nonfairTryAcquire是这个Sync中特定的方法，不是对父类对应方法的覆盖。

lock方法有对于FairSync和NoFairSync有两种不同的实现，对于非公平锁只要当前没有线程持有锁，就将锁给当前线程；而公平锁不能这么做，总是调用acquire方法来和其他线程一样公平的尝试获取锁。

比较公平锁机制和非公平锁机制的差别仅仅在于如果当前没有线程持有锁，是优先把锁分配给当前线程（非公平锁），还是优先分配给等待队列中队首的线程（公平锁）。

ReentrantLock总结： 

ReentrantLock中定义的同步器分为公平的同步器和非公平的同步器。在该同步器中state状态位表示当前持有锁的线程的重入次数。在获取锁时，通过覆盖AQS的tryAcquire(int arg)方法，如果没有线程持有锁则立即返回，并设置state为1；如果当前线程已经占有锁，则state加1；如果其他线程占有锁，则当前线程不可用。释放锁时，覆盖了AQS的tryRelease(int arg)，在该方法中主要作用是state状态位减少release个，表示释放锁，如果更新后的state为0，表示当前线程释放锁，如果不为0，表示持有锁的当前线程重入数减少。

既然有一个请求计数器和一个占有它的线程，即ReentrantLock实现了可重入锁。

总结对照

本文主要侧重AQS的子类在各个同步工具类中的使用情况，其实也基本涵盖了这几个同步工具类的主要逻辑，但目标并不是对这几个同步工具类的代码进行详细解析。另外AQS本身的几个final方法，才是同步器的公共基础，也不是本文的主题，也未详细展开。其实写这篇文章的一个初始目的真的只是想列出如下表格，对比下AQS中的各个子类是怎么使用state的，居然啰嗦了这么多。

参考：

http://ifeve.com/abstractqueuedsynchronizer-use/#more-18899

AQS的子类在各个同步工具类中的使用情况

标签：time   risc   state   out   void   vat   iter   targe   操作   

原文地址：https://www.cnblogs.com/theRhyme/p/9133901.html