在Java中如何实现可重入锁的并发控制_可重入锁操作经验分享

ReentrantLock通过可重入机制允许多次获取同一锁,需手动加锁并确保finally中释放;支持tryLock、Condition通信及公平性选择,提升并发控制灵活性。

在Java中实现可重入锁的并发控制,核心是使用ReentrantLock类。它不仅支持线程重复获取同一把锁,还提供了比synchronized更灵活的控制方式,比如尝试获取锁、带超时的获取、中断响应等。合理使用ReentrantLoc

k可以有效避免死锁、提升并发性能。

理解可重入锁的基本机制

ReentrantLock允许同一个线程多次获取同一把锁,每次获取锁计数加一,释放时计数减一,直到计数为零才真正释放锁。这种机制避免了线程因重复进入同步代码块而被自己阻塞。

对比synchronizedReentrantLock需要手动加锁和解锁,因此更灵活但也更易出错。必须确保在finally块中释放锁,防止死锁。

示例:

ReentrantLock lock = new ReentrantLock();

public void method() {
    lock.lock();
    try {
        // 临界区操作
        System.out.println("执行任务");
    } finally {
        lock.unlock(); // 必须在finally中释放
    }
}

使用tryLock避免无限等待

在高并发场景下,长时间等待锁可能导致线程堆积。使用tryLock()可以尝试获取锁,如果无法立即获得,可以选择放弃或执行其他逻辑。

常见用法包括:

  • tryLock():立即返回true或false
  • tryLock(long timeout, TimeUnit unit):在指定时间内尝试获取锁

适合用于资源争抢激烈但可降级处理的场景,例如缓存更新失败改走数据库查询。

结合Condition实现精准线程通信

ReentrantLock配合Condition可以替代wait/notify,实现更细粒度的线程等待与唤醒控制。

一个锁可以创建多个Condition,实现不同条件下的等待队列。例如生产者消费者模型中,可以用两个Condition分别表示“不满”和“不空”状态。

示例:

ReentrantLock lock = new ReentrantLock();
Condition notFull = lock.newCondition();
Condition notEmpty = lock.newCondition();

// 生产者
lock.lock();
try {
    while (queue.size() == CAPACITY) {
        notFull.await();
    }
    queue.add(item);
    notEmpty.signal();
} finally {
    lock.unlock();
}

注意公平性与性能权衡

ReentrantLock支持构造函数传入参数设置是否为公平锁:

  • new ReentrantLock(true):公平锁,按申请顺序获取锁,减少线程饥饿
  • new ReentrantLock(false):非公平锁(默认),性能更高,但可能造成某些线程长期等待

实际开发中,除非有明确的公平性需求,否则建议使用非公平锁,因为其吞吐量更高。

基本上就这些。掌握ReentrantLock的核心用法,注意锁的获取与释放配对、合理使用Condition和tryLock,就能在复杂并发场景中游刃有余。不复杂但容易忽略的是finally中的unlock——这是保障程序健壮性的关键。