Java并发编程-重入锁

章节目录

• 什么是重入锁
• 底层实现-如何实现重入
• 公平与非公平获取锁的区别与底层实现

1.什么是重入锁

1.1 重入锁的定义

重入锁ReentrantLock，支持重入的锁，表示一个线程对资源的重复加锁。 

1.2 重入锁的特性

1.重进入 2.非/公平性获取锁 

1.3 自定义同步器Mutex 的缺陷

当线程调用Mutex的lock()方法获取锁之后，再次调用lock()方法，该线程将会被 自己阻塞，原因是Mutex在实现tryAcquire(int acquires)方法时没有考虑占有锁 的线程再次获取锁的场景。 

1.4 ReentrantLock & synchronized 关键字

1.synchronized 关键字支持隐式的重进入 2.ReentrantLock 在调用lock() 方法时，已经获取到锁的线程，能够再次调用 lock()方法获取到锁而不被阻塞，即可支持重入 

1.4 公平性获取锁

公平性	含义
公平性获取锁	在绝对时间上，先对锁进行获取请求的请求一定先被满足，那么这个锁就是公平的
非公平性获取锁	无上述限制

事实上 公平锁机制往往没有非公平性机制获取锁的效率高，因为会牵扯到频繁的上下文切换，但公平锁可以减少饥饿发生的概率，等待越久的请求越能得到优先满足。

2. 底层实现-如何实现重入

重进入是指任意线程在获取到锁之后能够再次获取该锁，而不被阻塞，改特性实现需要解决以下两个问题：

• 线程再次获取锁

  线程再次获取锁。锁需要去识别获取锁的线程是否为当前占据锁的线程，如果是，则再次成功获取。 

• 锁的最终释放

  线程重复n次获取了锁，随后在第n次释放锁，锁的释放要求锁对于被获取递 增的次数进行递减操作，当计数==0时表示锁已经成功释放。 

2.1 可重入锁的源码
非公平性获取同步状态(锁)的 nonfairTryAcquire() 方法

 final boolean nonfairTryAcquire(int acquires) { final Thread current = Thread.currentThread(); int c = getState(); if (c == 0) { if (compareAndSetState(0, acquires)) { setExclusiveOwnerThread(current); return true; } } else if (current == getExclusiveOwnerThread()) { int nextc = c + acquires; if (nextc < 0) // overflow throw new Error("Maximum lock count exceeded"); setState(nextc); return true; } return false; } 

该方法增加了再次获取同步状态的处理逻辑:通过判断当前线程是否为获取锁的线程来决定获取操作是否成功，如果是获取锁的线程的再次请求 则将同步状态值计数器进行递增并返回true，表示获取同步状态成功。

释放同步状态(锁)

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); return free; } 

如果该锁被获取了n次，那么前n-1此tryRelease(int release) 方法必须返回false，而只有同步状态完全释放了，才能返回true。

3.公平与非公平获取锁的区别与底层实现

3.1 公平性获取锁的底层实现
公平性获取锁即按照客观时间顺序，FIFO方式获取同步状态
具体源码如下所示

 protected final boolean tryAcquire(int acquires) { final Thread current = Thread.currentThread(); int c = getState(); if (c == 0) { if (!hasQueuedPredecessors() && 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; } 

公平性获取同步状态的与非公平性获取同步状态的区别在于hasQueuedPredecessors()方法的使用，即加入了当前节点是否有前驱节点的判断，如果该方法返回true,则表示有线程比当前线程更早的加入到同步队列（更早的请求获取锁），因此需要等待前驱线程获取并释放锁之后才能继续获取锁。

非公平性获取锁的实现

• 公平性获取锁保证了锁的获取顺序按照FIFO原则，不会出现线程“饥饿”的现象，但代价是进行大量的线程切换。
• 非公平性锁虽然可能造成线程饥饿，但是有极少的线程切换，保证了其更大的吞吐量。