在Java中如何使用ReentrantLock锁机制

ReentrantLock 提供比 synchronized 更灵活的线程同步控制，支持可重入、公平锁、可中断、尝试加锁等特性。1. 基本使用需显式调用 lock() 和 unlock()，且 unlock() 必须在 finally 块中执行以确保释放。2. 可通过构造函数指定公平锁（true）以按请求顺序获取锁，但性能低于默认非公平锁。3. tryLock() 允许不阻塞尝试获取锁，支持超时机制，避免无限等待。4. lockInterruptibly() 使等待锁的线程可被中断，适用于可取消操作。5. 提供 isLocked、isHeldByCurrentThread、getHoldCount、hasQueuedThreads 等状态查询方法，便于监控。正确使用需始终保证锁的释放，防止死锁。

ReentrantLock 是 Java 并发包（java.util.concurrent.locks）中提供的一种可重入的互斥锁，相比 synchronized 关键字，它提供了更灵活的加锁机制，比如可中断、可定时、公平锁等特性。合理使用 ReentrantLock 可以更好地控制线程同步。

1. 基本使用方式

使用 ReentrantLock 的基本步骤是：创建锁对象，调用 lock() 方法加锁，执行临界区代码，最后在 finally 块中调用 unlock() 释放锁。

示例代码：

立即学习“Java免费学习笔记（深入）”；

import java.util.concurrent.locks.ReentrantLock;

public class Counter {
    private int count = 0;
    private final ReentrantLock lock = new ReentrantLock();

    public void increment() {
        lock.lock();  // 获取锁
        try {
            count++;
        } finally {
            lock.unlock();  // 释放锁
        }
    }

    public int getCount() {
        lock.lock();
        try {
            return count;
        } finally {
            lock.unlock();
        }
    }
}

2. 公平锁与非公平锁

ReentrantLock 支持公平锁和非公平锁。默认是非公平锁，即不保证等待时间最长的线程优先获取锁。

如果希望线程按请求顺序获取锁，可以在构造时传入 true 启用公平模式：

private final ReentrantLock lock = new ReentrantLock(true); // 公平锁

3. 尝试获取锁（tryLock）

ReentrantLock 提供了 tryLock() 方法，尝试获取锁而不阻塞。如果当前锁可用，则获取成功；否则立即返回 false。

歌者PPT

歌者PPT，AI 写 PPT 永久免费

下载

也可以设置超时时间，指定最多等待多久获取锁。

示例：

if (lock.tryLock()) {
    try {
        // 执行操作
    } finally {
        lock.unlock();
    }
} else {
    // 锁被占用，做其他处理
}

带超时的 tryLock：

if (lock.tryLock(1, TimeUnit.SECONDS)) {
    try {
        // 成功获取锁
    } finally {
        lock.unlock();
    }
} else {
    // 超时未获取到锁
}

4. 可中断锁（lockInterruptibly）

当线程调用 lock() 等待锁时，无法被中断。而使用 lockInterruptibly() 可以使等待中的线程响应中断。

适用于需要取消等待的场景。

示例：

lock.lockInterruptibly();
try {
    // 临界区操作
} catch (InterruptedException e) {
    // 处理中断
    Thread.currentThread().interrupt(); // 恢复中断状态
} finally {
    if (lock.isHeldByCurrentThread()) {
        lock.unlock();
    }
}

5. 查询锁状态

ReentrantLock 还提供了一些方法用于监控锁的状态：

• isLocked()：判断锁是否被某个线程持有
• isHeldByCurrentThread()：判断当前线程是否持有该锁
• getHoldCount()：返回当前线程持有锁的次数（可重入）
• hasQueuedThreads()：是否有线程在等待此锁

这些方法适合用于调试或监控系统运行状态。