本文共 1335 字，大约阅读时间需要 4 分钟。

        AbstractQueuedSynchronizer类如其名，抽象的队列式的同步器，AQS定义了一套多线程访问共享资源的同步器框架，许多同步类实现都依赖于它，如常用的ReentrantLock/Semaphore/CountDownLatch。

        它维护了一个volatile int state（代表共享资源）和一个FIFO线程等待队列（多线程争用资源被阻塞时会进入此队列）。这里volatile是核心关键词。state的访问方式有三种: getState() setState() compareAndSetState()。

• Exclusive独占资源-ReentrantLock：独占，只有一个线程能执行，如ReentrantLock
• Share共享资源-Semaphore/CountDownLatch ：共享，多个线程可同时执行，如Semaphore/CountDownLatch。

同步状态的获取与释放

        如果获取到资源，线程直接返回，否则进入等待队列，直到获取到资源为止，且整个过程忽略中断的影响。包含以下操作。

• tryAcquire：去尝试获取锁，获取成功则设置锁状态并返回true，否则返回false。该方法由自定义同步组件自己实现（通过state的get/set/CAS），该方法必须要保证线程安全的获取同步状态。
• addWaiter：如果tryAcquire返回FALSE（获取同步状态失败），则调用该方法将当前线程加入到CLH同步队列尾部，并标记为独占模式。
• acquireQueued：当前线程会根据公平性原则来进行阻塞等待（自旋）,直到获取锁为止；如果在整个等待过程中被中断过，则返回true，否则返回false。
• selfInterrupt：如果线程在等待过程中被中断过，它是不响应的。只是获取资源后才再进行自我中断selfInterrupt()，将中断补上。

        当前线程会一直尝试获取同步状态，当然前提是只有其前驱节点为头结点才能够尝试获取同步状态

1、保持FIFO同步队列原则。 2、头节点释放同步状态后，将会唤醒其后继节点，后继节点被唤醒后需要检查自己是否为头节点。`

        检查当前线程是否需要被阻塞，具体规则如下：

1. 如果当前线程的前驱节点状态为SINNAL，则表明当前线程需要被阻塞，调用unpark()方法唤醒，直接返回true，当前线程阻塞 2. 如果当前线程的前驱节点状态为CANCELLED（ws > 0），则表明该线程的前驱节点已经等待超时或者被中断了，则需要从CLH队列中将该前驱节点删除掉，直到回溯到前驱节点状态 <= 0 ，返回false 3. 如果前驱节点非SINNAL，非CANCELLED，则通过CAS的方式将其前驱节点设置为SINNAL，返回false。整个流程中，如果前驱结点的状态不是SIGNAL，那么自己就不能被阻塞，需要去找个安心的休息点（前驱节点状态 <= 0 ），同时可以再尝试下看有没有机会去获取资源。如果 shouldParkAfterFailedAcquire(Node pred, Node node) 方法返回true，则调用parkAndCheckInterrupt()方法阻塞当前线程。

转载地址：http://mnjzb.baihongyu.com/