ReentrantReadWriteLock：Java多线程并发编程的利器

2023-12-17 01:28:45

ReentrantReadWriteLock概述

ReentrantReadWriteLock是一种读写锁，它允许多个线程同时读写共享数据。与普通的锁不同，ReentrantReadWriteLock允许多个线程同时读取共享数据，但只能允许一个线程写入共享数据。这种设计可以大大提高并发程序的性能，因为读操作通常比写操作要频繁得多。

ReentrantReadWriteLock的实现使用了两个锁：一个读锁和一个写锁。读锁可以被多个线程同时获取，而写锁只能被一个线程获取。当一个线程获取了读锁时，其他线程只能获取读锁，不能获取写锁。当一个线程获取了写锁时，其他线程都不能获取读锁和写锁。

ReentrantReadWriteLock还支持重入，这意味着一个线程可以多次获取读锁或写锁。当一个线程获取了读锁时，它可以再次获取读锁，但不能获取写锁。当一个线程获取了写锁时，它可以再次获取写锁，但不能获取读锁。

ReentrantReadWriteLock的使用

ReentrantReadWriteLock的使用非常简单，只需要遵循以下步骤：

创建一个ReentrantReadWriteLock对象。
使用ReentrantReadWriteLock对象的readLock()方法获取读锁。
使用ReentrantReadWriteLock对象的writeLock()方法获取写锁。
对共享数据进行读写操作。
释放读锁或写锁。

以下是一个使用ReentrantReadWriteLock的示例代码：

import java.util.concurrent.locks.ReentrantReadWriteLock;

public class ReentrantReadWriteLockExample {

    private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();

    private int value = 0;

    public void read() {
        lock.readLock().lock();
        try {
            System.out.println("The value is " + value);
        } finally {
            lock.readLock().unlock();
        }
    }

    public void write() {
        lock.writeLock().lock();
        try {
            value++;
            System.out.println("The value is now " + value);
        } finally {
            lock.writeLock().unlock();
        }
    }

    public static void main(String[] args) {
        ReentrantReadWriteLockExample example = new ReentrantReadWriteLockExample();

        Thread t1 = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                example.read();
            }
        });

        Thread t2 = new Thread(() -> {
            for (int i = 0; i < 10; i++) {
                example.write();
            }
        });

        t1.start();
        t2.start();
    }
}