深入理解ReentrantLock的底层实现与应用
Java中的ReentrantLock是一个强大的可重入锁,提供了比传统的synchronized关键字更灵活的互斥性和可重入性。本文将深入探讨ReentrantLock的底层实现和一些常见的应用场景,并结合Java代码进行详细讲解。
1. ReentrantLock的基本使用
首先,让我们看一下ReentrantLock的基本用法:
import java.util.concurrent.locks.ReentrantLock; public class ReentrantLockExample { private static final ReentrantLock lock = new ReentrantLock(); public static void main(String[] args) { // 启动两个线程演示ReentrantLock的基本用法 new Thread(ReentrantLockExample::doSomething).start(); new Thread(ReentrantLockExample::doSomething).start(); } private static void doSomething() { lock.lock(); try { // 临界区,线程在此处执行需要互斥的操作 System.out.println(Thread.currentThread().getName() + " is in the critical section."); } finally { lock.unlock(); } } }
在上述代码中,我们创建了一个ReentrantLock实例lock,然后启动了两个线程,在doSomething方法中通过lock实现了对临界区的互斥访问。这是ReentrantLock的基本使用方式。
2. ReentrantLock的底层实现
2.1 Sync抽象类
ReentrantLock的底层实现依赖于AbstractQueuedSynchronizer(AQS)类。ReentrantLock包含一个抽象内部类Sync,它继承了AbstractQueuedSynchronizer,实现了锁的基本同步语义。
abstract static class Sync extends AbstractQueuedSynchronizer { // ... }
2.2 FairSync和NonfairSync类
Sync有两个具体实现:FairSync和NonfairSync,分别对应于公平锁和非公平锁。公平锁会按照线程等待的顺序获取锁,而非公平锁则允许一个线程插队获取锁。
static final class NonfairSync extends Sync { // ... } static final class FairSync extends Sync { // ... }
2.3 ReentrantLock构造方法
在ReentrantLock的构造方法中,根据用户的选择创建相应类型的Sync实例:
public ReentrantLock() { sync = new NonfairSync(); } public ReentrantLock(boolean fair) { sync = fair ? new FairSync() : new NonfairSync(); }
2.4 lock和unlock操作
ReentrantLock的lock()方法和unlock()方法最终调用Sync中的相应方法。lock()方法尝试获取锁,如果当前线程已经持有锁,则增加锁的计数;如果锁已经被其他线程持有,则当前线程将被阻塞。unlock()方法用于释放锁。
public void lock() { sync.lock(); } public void unlock() { sync.unlock(); }
3. 应用场景
3.1 可重入性
ReentrantLock支持可重入性,同一个线程可以多次获取锁,而不会发生死锁。这是通过Sync中的tryAcquire和tryRelease方法实现的。
public void nestedLockExample() { lock.lock(); try { // some critical section nestedMethod(); } finally { lock.unlock(); } } private void nestedMethod() { lock.lock(); try { // nested critical section } finally { lock.unlock(); } }
3.2 公平锁与非公平锁
ReentrantLock提供了公平锁和非公平锁的选择。在构造方法中传入true创建公平锁,传入false(或使用默认构造方法)创建非公平锁。
ReentrantLock fairLock = new ReentrantLock(true); // 公平锁 ReentrantLock nonfairLock = new ReentrantLock(); // 非公平锁
3.3 条件等待
ReentrantLock通过newCondition方法提供了Condition接口的实现,可以用于在锁上等待和唤醒线程。
Condition condition = lock.newCondition(); lock.lock(); try { while (someConditionIsTrue()) { condition.await(); } // some critical section } finally { lock.unlock(); }