在Java中如何使用ReentrantReadWriteLock实现读写锁

P粉602998670 2025-10-14 00:00:00 次阅读

ReentrantReadWriteLock适用于读多写少场景，通过读锁共享、写锁独占实现高效并发控制。示例中缓存类用读锁允许多线程读取，写锁确保更新时排他访问。支持写锁降级为读锁，保证检查与更新的原子性，避免死锁需在finally释放锁，且写锁才能创建Condition。合理使用可提升并发性能。

在Java中，ReentrantReadWriteLock 是一种高效的同步工具，适用于读多写少的并发场景。它允许多个线程同时读取共享资源，但写操作是独占的，确保数据一致性。下面介绍如何正确使用它。

读锁与写锁的基本原理

ReentrantReadWriteLock 维护了一对锁：一个用于读操作的共享锁，一个用于写操作的排他锁。

多个线程可以同时持有读锁，只要没有线程持有写锁。
写锁是独占的，一旦某个线程获取了写锁，其他所有读、写线程都会被阻塞。
写锁可以降级为读锁，但读锁不能升级为写锁。

基本使用示例

以下是一个简单的缓存类，使用 ReentrantReadWriteLock 来保护数据访问：

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.ReentrantReadWriteLock;

public class ReadWriteCache {
    private final Map cache = new HashMap<>();
    private final ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock();

    public Object get(String key) {
        rwLock.readLock().lock();
        try {
            return cache.get(key);
        } finally {
            rwLock.readLock().unlock();
        }
    }

    public Object put(String key, Object value) {
        rwLock.writeLock().lock();
        try {
            return cache.put(key, value);
        } finally {
            rwLock.writeLock().unlock();
        }
    }
}

在这个例子中，get 方法使用读锁，允许多个线程并发读取；put 方法使用写锁，确保写入时不会有其他读或写操作干扰。

锁降级的使用场景

有时需要在修改数据前先读取，再更新，这时可以通过“锁降级”保证原子性：

rwLock.readLock().lock();
try {
    if (!isValid()) {
        // 释放读锁，准备获取写锁
        rwLock.readLock().unlock();
        rwLock.writeLock().lock();
        try {
            // 再次检查条件（防止其他线程已修改）
            if (!isValid()) {
                update();
            }
            // 获取读锁后再释放写锁，实现降级
            rwLock.readLock().lock();
        } finally {
            rwLock.writeLock().unlock();
        }
    }
    // 现在仍持有读锁，可以安全读取
    useData();
} finally {
    rwLock.readLock().unlock();
}

这种模式确保了从“检查”到“更新”的过程不会被中断，且最终仍能以读锁方式继续访问数据。