17370845950

在Java中如何使用ReentrantLock实现线程同步_ReentrantLock操作实践经验
ReentrantLock提供比synchronized更灵活的线程同步机制,支持显式加锁解锁、公平锁选择、可中断等待和超时获取锁;正确使用需确保unlock在finally中执行,避免死锁;tryLock适用于多锁竞争场景,降低死锁风险;默认非公平锁性能更优,公平锁适用于需FIFO调度的场景;lockInterruptibly支持中断等待,适合可取消任务;合理运用这些特性可提升并发安全性与效率。

在Java多线程编程中,ReentrantLock 是一种比 synchronized 更灵活、功能更强大的可重入锁机制。它位于 java.util.concurrent.locks 包下,提供了显式的加锁和释放锁操作,支持公平锁与非公平锁、可中断等待、超时获取锁等高级特性。下面结合实际使用场景,介绍如何正确使用 ReentrantLock 实现线程同步,并总结一些实践经验。

一、基本用法:加锁与释放锁

使用 ReentrantLock 的核心是手动控制 lock() 和 unlock() 方法的调用。必须确保 unlock() 在 finally 块中执行,防止死锁。

示例代码:

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();
        }
    }
}

说明:lock() 方法阻塞直到获得锁,unlock() 必须放在 finally 中,确保即使发生异常也能释放锁。

二、避免死锁:尝试获取锁与超时机制

相比 synchronized,ReentrantLock 提供了 tryLock() 方法,允许线程在指定时间内尝试获取锁,避免无限等待。

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

适用场景:多个线程竞争资源时,希望快速失败或重试。

示例:

public boolean safeTransfer(Account from, Account to, double amount) {
    if (from.getLock().tryLock()) {
        try {
            if (to.getLock().tryLock()) {
                try {
                    if (from.getBalance() >= amount) {
                        from.debit(amount);
                        to.credit(amount);
                        return true;
                    }
                } finally {
                    to.getLock().unlock();
                }
            }
        } finally {
            from.getLock().unlock();
        }
    }
    return false; // 获取锁失败,放弃转账
}

建议:处理多个锁时,使用 tryLock 配合重试逻辑,降低死锁风险。

三、公平锁 vs 非公平锁

ReentrantLock 构造函数支持指定是否为公平锁:

  • new ReentrantLock():默认为非公平锁,性能更高,但可能造成线程“饥饿”。
  • new ReentrantLock(true):公平锁,按等待顺序获取锁,更公平但吞吐量略低。

实践中建议:

  • 大多数场景使用默认非公平锁即可,性能更好。
  • 仅在需要严格 FIFO 调度时启用公平模式,如任务调度系统。

四、可中断的锁等待

ReentrantLock 支持 lockInterruptibly() 方法,允许线程在等待锁的过程中响应中断。

适用于长时间等待可能被取消的操作,如用户主动取消任务。

示例:

public void interruptibleMethod() throws InterruptedException {
    lock.lockInterruptibly();
    try {
        // 执行耗时操作
        Thread.sleep(5000);
    } finally {
        lock.unlock();
    }
}

当其他线程调用该线程的 interrupt() 方法时,lockInterruptibly() 会抛出 InterruptedException,及时退出。

基本上就这些。合理使用 ReentrantLock 可以提升程序的并发控制能力,但要特别注意 lock 和 unlock 的配对,避免资源泄漏或死锁。掌握 tryLock、中断和公平性设置,能让线程同步更安全、更高效。