您现在的位置:首页 >> 基础 >> Java编程 >> 内容

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

时间:2020-12-28 9:18:20

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

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

为了更好地解决多个线程读写带来的并发问题, 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()) , 那么另一个线程也可以读取该读锁中的资源, 运行结果如图所示。

如果一个线程获取了写锁(writeLock().lock()) , 那么另一个线程就必须等待写锁的释放, 运行结果如图所示。

 

Java免费学习   Java自学网 http://www.javalearns.com

关注微信号:javalearns   随时随地学Java

或扫一扫

随时随地学Java

作者:不详 来源:网络
    你是从哪里知道本网站的?
  • 网友介绍的
  • 百度搜索的
  • Google搜索的
  • 其它搜索过来的
  • 网址输错了进来的
  • 太忙了不记得了
共有评论 0相关评论
发表我的评论
  • 大名:
  • 内容:
  • java学习网(www.javalearns.com) © 2014 版权所有 All Rights Reserved.
  • Email:javalearns@163.com 站长QQ:1356121699 晋ICP备14003680号-3
  • java学习网部分内容来自网络或网友发布,如侵犯了您利益,请发邮件至:javalearns@126.com,我们尽快处理!
  • Java学习网
  • 网站统计
  • 晋公网安备 14042902000001号