锁内存语义的实现

本文将借助ReentrantLock的源代码，来分析锁内存语义的具体实现机制。
请看下面的示例代码：
class ReentrantLockExample {

         int a = 0;

        ReentrantLock lock = new ReentrantLock();

       public void writer() {  

              lock.lock();         //获取锁   

            try {

                    a++;    

                } finally {

               lock.unlock();  //释放锁    

             }

          }

         public void reader () {  

              lock.lock();        //获取锁   

              try {

                       int i = a;        …… 

                } finally {    

                   lock.unlock();  //释放锁    

              }

          }

} 

在ReentrantLock中，调用lock()方法获取锁；调用unlock()方法释放锁。
ReentrantLock的实现依赖于java同步器框架AbstractQueuedSynchronizer（本文简称之为AQS）。AQS使用一个整型的volatile变量（命名为state）来维护同步状态，马上我们会看到，这个volatile变量是ReentrantLock内存语义实现的关键。 下面是ReentrantLock的类图（仅画出与本文相关的部分）：


ReentrantLock分为公平锁和非公平锁，我们首先分析公平锁。
使用公平锁时，加锁方法lock()的方法调用轨迹如下：

• ReentrantLock : lock()
• FairSync : lock()
• AbstractQueuedSynchronizer : acquire(int arg)
• ReentrantLock : tryAcquire(int acquires)

在第4步真正开始加锁，下面是该方法的源代码：
protected final boolean tryAcquire(int acquires) {

            final Thread current = Thread.currentThread();

            int c = getState();   //获取锁的开始，首先读volatile变量state

            if (c == 0) {

                  if (isFirst(current) && compareAndSetState(0, acquires)) {

                  setExclusiveOwnerThread(current);

                  return true;  

                 }

            }    else if (current == getExclusiveOwnerThread()) {   

               int nextc = c + acquires;     

              if (nextc < 0)    

                   throw new Error(“Maximum lock count exceeded”);  

              setState(nextc);   

             return true;  

          }   

         return false;

    } 

从上面源代码中我们可以看出，加锁方法首先读volatile变量state。
在使用公平锁时，解锁方法unlock()的方法调用轨迹如下：

• ReentrantLock : unlock()
• AbstractQueuedSynchronizer : release(int arg)
• Sync : tryRelease(int releases)

在第3步真正开始释放锁，下面是该方法的源代码：
protected final boolean tryRelease(int releases) { 

            int c = getState() – releases; 

            if (Thread.currentThread() != getExclusiveOwnerThread())        

                      throw new IllegalMonitorStateException();

             boolean free = false; 

            if (c == 0) {  

                  free = true;   

                 setExclusiveOwnerThread(null);

              }  

           setState(c);           //释放锁的最后，写volatile变量state    

          return free;

} 

从上面的源代码我们可以看出，在释放锁的最后写volatile变量state。
公平锁在释放锁的最后写volatile变量state；在获取锁时首先读这个volatile变量。根据volatile的happens-before规则，释放锁的线程在写volatile变量之前可见的共享变量，在获取锁的线程读取同一个volatile变量后将立即变的对获取锁的线程可见。
现在我们分析非公平锁的内存语义的实现。
非公平锁的释放和公平锁完全一样，所以这里仅仅分析非公平锁的获取。
使用非公平锁时，加锁方法lock()的方法调用轨迹如下：

• ReentrantLock : lock()
• NonfairSync : lock()
• AbstractQueuedSynchronizer : compareAndSetState(int expect, int update)

在第3步真正开始加锁，下面是该方法的源代码：
protected final boolean compareAndSetState(int expect, int update) { 

          return unsafe.compareAndSwapInt(this, stateOffset, expect, update);

} 

该方法以原子操作的方式更新state变量，本文把java的compareAndSet()方法调用简称为CAS。JDK文档对该方法的说明如下：如果当前状态值等于预期值，则以原子方式将同步状态设置为给定的更新值。此操作具有 volatile 读和写的内存语义。
这里我们分别从编译器和处理器的角度来分析,CAS如何同时具有volatile读和volatile写的内存语义。
前文我们提到过，编译器不会对volatile读与volatile读后面的任意内存操作重排序；编译器不会对volatile写与volatile写前面的任意内存操作重排序。组合这两个条件，意味着为了同时实现volatile读和volatile写的内存语义，编译器不能对CAS与CAS前面和后面的任意内存操作重排序。
下面我们来分析在常见的intel x86处理器中，CAS是如何同时具有volatile读和volatile写的内存语义的。
  
intel的手册对lock前缀的说明如下：

• 确保对内存的读-改-写操作原子执行。在Pentium及Pentium之前的处理器中，带有lock前缀的指令在执行期间会锁住总线，使得其他处理器暂时无法通过总线访问内存。很显然，这会带来昂贵的开销。从Pentium 4，Intel Xeon及P6处理器开始，intel在原有总线锁的基础上做了一个很有意义的优化：如果要访问的内存区域（area of memory）在lock前缀指令执行期间已经在处理器内部的缓存中被锁定（即包含该内存区域的缓存行当前处于独占或以修改状态），并且该内存区域被完全包含在单个缓存行（cache line）中，那么处理器将直接执行该指令。由于在指令执行期间该缓存行会一直被锁定，其它处理器无法读/写该指令要访问的内存区域，因此能保证指令执行的原子性。这个操作过程叫做缓存锁定（cache locking），缓存锁定将大大降低lock前缀指令的执行开销，但是当多处理器之间的竞争程度很高或者指令访问的内存地址未对齐时，仍然会锁住总线。
• 禁止该指令与之前和之后的读和写指令重排序。
• 把写缓冲区中的所有数据刷新到内存中。

上面的第2点和第3点所具有的内存屏障效果，足以同时实现volatile读和volatile写的内存语义。
经过上面的这些分析，现在我们终于能明白为什么JDK文档说CAS同时具有volatile读和volatile写的内存语义了。
现在对公平锁和非公平锁的内存语义做个总结：

• 公平锁和非公平锁释放时，最后都要写一个volatile变量state。
• 公平锁获取时，首先会去读这个volatile变量。
• 非公平锁获取时，首先会用CAS更新这个volatile变量,这个操作同时具有volatile读和volatile写的内存语义。

从本文对ReentrantLock的分析可以看出，锁释放-获取的内存语义的实现至少有下面两种方式：

• 利用volatile变量的写-读所具有的内存语义。
• 利用CAS所附带的volatile读和volatile写的内存语义。

concurrent包的实现

由于java的CAS同时具有 volatile 读和volatile写的内存语义，因此Java线程之间的通信现在有了下面四种方式：

• A线程写volatile变量，随后B线程读这个volatile变量。
• A线程写volatile变量，随后B线程用CAS更新这个volatile变量。
• A线程用CAS更新一个volatile变量，随后B线程用CAS更新这个volatile变量。
• A线程用CAS更新一个volatile变量，随后B线程读这个volatile变量。

Java的CAS会使用现代处理器上提供的高效机器级别原子指令，这些原子指令以原子方式对内存执行读-改-写操作，这是在多处理器中实现同步的关键（从本质上来说，能够支持原子性读-改-写指令的计算机器，是顺序计算图灵机的异步等价机器，因此任何现代的多处理器都会去支持某种能对内存执行原子性读-改-写操作的原子指令）。同时，volatile变量的读/写和CAS可以实现线程之间的通信。把这些特性整合在一起，就形成了整个concurrent包得以实现的基石。如果我们仔细分析concurrent包的源代码实现，会发现一个通用化的实现模式：

• 首先，声明共享变量为volatile；
• 然后，使用CAS的原子条件更新来实现线程之间的同步；
• 同时，配合以volatile的读/写和CAS所具有的volatile读和写的内存语义来实现线程之间的通信。

AQS，非阻塞数据结构和原子变量类（java.util.concurrent.atomic包中的类），这些concurrent包中的基础类都是使用这种模式来实现的，而concurrent包中的高层类又是依赖于这些基础类来实现的。从整体来看，concurrent包的实现示意图如下：