一：引子

InnoDB是符合MVCC(Multi-Version Concurrency Control)规范的，通俗的讲就是写加锁，读不加锁，读写不冲突(有些情况下是不符合MVCC的，比如当isolation级别为serializable时，是读写冲突的，这又跟autocommit参数的值有关，这里不展开讲)。有这么一个前提mysql才能对并发有不错的处理能力，但是很多时候我们不希望多个线程同时修改同一个数据，我们的做法就是设置isolation的级别，保证数据的一致性。我们接下来就来探讨下InnoDB中的同步机制。

二：为什么要同步机制

比如我们现在mysql-server上跟客户端建立里3个连接,某一时刻这个三个连接同时发来了一个请求，需要把名为"bugall"的用户的money增加10000，在这个时候你不希望别的连接再来修改这个值，通常我们会在"bugall"这个用户的数据上加一把排它锁，这样的话所有的对"bugall"对应数据做修改的请求连接都会被序列化，对"bugall"做修改的时候其它修改的请求都会被阻塞。这个阻塞过程是怎么实现的呢?或是说这个同步机制是怎么实现的?我们接着往下看。

三：内存模型

内存模型决定里CPU怎样访问内存,以及并发情况下各CPU之间的影响。但是内存模型并不包括虚拟地址转换,因为最终CPU访问的内存的物理地址，内存模型主要关心的是CPU和内存之间数据和物理地址的传输。不同硬件之间内存模型的差异在于硬件是根据怎样的顺序来执行load和store指令，改变执行顺序或许有可能带性能的提升，除此之外,内存模型还指定了多个处理器访问同一内存地址的行为，最简单的内存模型就是顺序内存模型(sequential memory model),也称为strong ordering，在这个模型下,所有的load和store指令是根据程序运行顺序执行的。

1. load %r1,A //将内存地址A中的值放入寄存器r1 
2. load %r2,B //将内存地址B中的值放入寄存器r2 
3. add %r3,%r1,%r2 //将寄存器r1与r2的值相加,并放入寄存器r3 
4. store %r3,c //将寄存器r3中的值写入到内存地址c中  

在数序内存模型下,执行的顺序都是按照程序运行的顺序进行的，若还未将内存地址A中的值取到，则不能执行从内存地址B中取值的操作除了要求内存操作的顺序与程序运行顺序一致，顺序内存模型， 还要求从CPU或者I/O设备中读取或者写入操作是原子的,即一旦开始了，这些操作就不能被其他的内存操作中断 。

四：临界区与互斥

虽然顺序内存模型的执行顺序是根据程序的运行顺序，但是多个CPU对同一个内存地址的访问顺序确实不确定的，而正是因为少里访问的确定性从而导致竞争(race condition)条件的发生。为了说明这个问题，假设有一个全局的计数器counter，CPU操作每次将该值加1，同时要求该计数器需要非常精确的展示当前CPU的操作次数 。

1. load %r1,counter //将计数器counter的值读取到寄存器r1 
2. add %r1,1 //将寄存器r1中的值加1 
3. store %r1,counter //并存放到计数器counter中 

接下来有两种CPU顺序的执行累加操作

在该顺序下,两个CPU执行的时间交错,没有发生race condition，因此最后得到的值符合之前的预期,然而,还有一种可能性。

 

可以发现:若当两个CPU同时进行load操作时,那么最终将会产生错误的结果。因为每个CPU在自增前读到的数据都是0,那么不管之后的操作顺寻如何,得到的结果永远会是1,而正确的值应为2。

在两个或者多个CPU之间更新共享的数据结构指令序列会产生race condition，指令序列本身称为临界区(critical section)，操作的数据称为临界资源(critical resource)。如上面代码中的三个指令序列可视为临界区,为里消除多个CPU并发访问临界区而导致的race condition，故需要限制同一个时刻只允许一个CPU执行临界区，而这就是互斥(mutex exclusion)。

五：原子操作

为了保证同一时刻只允许一个CPU执行临界区，当前硬件都提供里基于原子的read-modify-write操作。read-modify-write操作允许一个CPU读取一个值，修改该值,并将修改完成的值写回到内存的三个操作作为一个原子总线操作，其在CPU中是一个特别的指令，并且只有在需要同步的时候才使用。对于具体进行怎样的modify操作每个实现标准可能并不相同，但通常来说，目前的CPU都支持test-and-set(TAS)指令，该指令从内存中读取一个字节或者一个word(4个字节)，然后和0进行比较，并且无条件的将其在内存中的值设置为1，所有这些操作都是原子操作。一旦CPU在执行test-and-set操作，其它任何CPU和I/O设备都不能使用总线，通过test-and-set指令，操作系统或者数据库系统可以构造更高级别的同步操作，如spin lock(自旋锁)，semephore(信号量)。

六：自旋锁

在TAS的基础上，可以实现很多互斥的数据结构，而spin lock则是使用最为广泛,也最为简单的一种互斥结构。spin lock使用来对short-term critical section进行互斥的数据结构，特别需要注意的是，spin lock用来互斥的critical section的代码应该比较少，即一般可以较快执行完代码，并释放spin lock，因为spin lock会使其它需要获取锁的线程进入忙等,占用CPU。为在多CPU环境中利用test_and_set指令实现进程互斥，硬件需要提供进一步的支持，以保证test_and_set指令执行的原子性。这种支持目前多以"锁总线"(bus locking)的形式提供的，由于test_and_set指令对内存的两次操作都需要经过总线,在执行test_and_set指令之前锁住总线,在执行test_and_set指令后锁定总线,即可保证test_and_set指令执行的原子性。

七：自旋锁实现

实现最基本的TAS指令就是使用swap-atomic操作。该操作仅仅将寄存器中的值与内存的值进行交换，通过swap-atomic 可以用来构造test-and-set操作，首先将寄存器中的值设置为1，然后执行atomic swap,最后和寄存器中的值进行比较。

1. int 
2.   test_and_set(volatile int* addr){ 
3.       int old_value; 
4.       old_value = swap_atomic(addr,1); 
5.       if(old_value==0){ 
6.           return 0; 
7.       } 
8.       return 1; 
9.   }   

变量addr的类型是init，表明需要操作的单位是word.volatile修饰词告诉编译器从内存中读取addr的值，因为即使本操作没有修改addr的值，其它CPU也可能修改该值,那么在这中情况下，可能会导致执行test_and_set得到错误的结果。swap_atomic函数执行swap-atomic的硬件指令,并返回交换前内存中addr的值，test-and-set操作是由两个独立的操作组合为一个指令，第一个阶段是将addr中的值设置为1,第二阶段比较之前取得的结果。初始化时，将其值设置为0 。

1. typedef init lock_t 
2.    void 
3.    initlock(volatile lock_t *lock_status){ 
4.        *lock_status =  0; 
5.    }  

使用前面的TAS方法讲一个spin lock对象上锁

1. void 
2.     lock(volatile lock_t* lock_statue){ 
3.         while(test_and_set(lock_status)==1); 
4.     }  

当lock_status的值为0时,test_and_set返回的结果为0,上锁成功。若该对象已经被使用,那么需要在while中循环(spin),知道对象释放锁。这也是spin lock名字的由来。

本文作者：佚名

来源：51CTO