Java项目实践，使用ReadWriteLock解决并发问题

用户1289394

发布于 2021-01-06 00:05:26

6530

文章被收录于专栏：Java学习网Java学习网

在多线程的环境下，对同一份数据进行读写，会涉及到线程安全的问题。比如在一个线程读取数据的时候，另外一个线程在写数据，而导致前后数据的不一致性；一个线程在写数据的时候，另一个线程也在写，同样也会导致线程前后看到的数据的不一致性。

为了更好地解决多个线程读写带来的并发问题， JUC还提供了专门的读写锁ReadWriteLock，可以分别用于对读操作或写操作进行加锁， ReadWriteLock在JDK中的源码如下。

【源码java.util.concurrent.locks.ReadWriteLock】

package java.utl.concurrent.locks；

public interface ReadWriteLock{

Lock readLock();

Lock writeLock();

}

源码中readLock() 和writeLock() 的含义如下:

1、readLock()：读锁。加了读锁的资源，可以在没有写锁的时候被多个线程共享。换句话说，如果tl线程已经获取了读锁，那么此时存在以下状态：

(1)、如果t2线程要申请写锁，则t2会一直等待t1释放读锁；

(2)、如果t2线程要申请读锁，则t2可以直接访问读锁，也就是说t1和t2可以共享资源，就和没加锁的效果一样。

2、writeLock()：写锁，是独占锁。加了写锁的资源，不能再被其他线程读或写。换句话说，如果山已经获取了写锁，那么此时无论线程t2要申请写锁还是读锁，都必须等待t1释放写锁。

测试代码如下：

public class TestReadWriteLock {
	// 读写锁
		private ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
		public static void main(String[] args) {
			TestReadWriteLock test = new TestReadWriteLock();
			//t1线程
			new Thread(() -> {
				//读操作
				test.myRead(Thread.currentThread());
				//写操作
				test.myWrite(Thread.currentThread());
			},"t1").start();
			
			//t2线程
			new Thread(() -> {
				//读操作
				test.myRead(Thread.currentThread());
				//写操作
				test.myWrite(Thread.currentThread());
			},"t2").start();

		}

		//用读锁来锁定读操作
		public void myRead(Thread thread) {
			rwl.readLock().lock();
			try {
				for (int i = 0; i < 10; i++) {
					System.out.println(thread.getName() + "正在进行读操作");
				}
				System.out.println(thread.getName() + "===读操作完毕===");
			} finally {
				rwl.readLock().unlock();
			}
		}

		//用写锁来锁定写操作
		public void myWrite(Thread thread) {
			rwl.writeLock().lock();
			try {
				for (int i = 0; i < 10; i++) {
					System.out.println(thread.getName() + "正在进行写操作");
				}
				System.out.println(thread.getName() + "===写操作完毕===");
			} finally {
				rwl.writeLock().unlock();
			}
		}
}

测试代码中有2个线程，如果一个线程获取了读锁(readLock().lock()) ，那么另一个线程也可以读取该读锁中的资源，运行结果如图所示。