java的ReentrantReadWriteLock不能锁升级的原因是什么

本篇内容介绍了“java的ReentrantReadWriteLock不能锁升级的原因是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

为什么ReentrantReadWriteLock不能锁升级

ReentrantReadWriteLock中,锁是不可以升级的,只能降级。

也就是如果当前线程持有了ReadLock,那么就不能再获取WriteLock,但是,如果当前线程持有了WriteLock,可以直接获取ReadLock

下面用代码尝试一下:

Logger logger = LoggerFactory.getLogger(this.getClass());
ReentrantReadWriteLock reentrantReadWriteLock = new ReentrantReadWriteLock();
ReentrantReadWriteLock.ReadLock readLock = reentrantReadWriteLock.readLock();
ReentrantReadWriteLock.WriteLock writeLock = reentrantReadWriteLock.writeLock();
logger.info("线程:[{}],开始readLock",Thread.currentThread().getName());
readLock.lock();
logger.info("线程:[{}],readLock成功",Thread.currentThread().getName());
logger.info("线程:[{}],开始writeLock",Thread.currentThread().getName());
writeLock.lock();
logger.info("线程:[{}],writeLock成功",Thread.currentThread().getName());

从打印结果可以看出来,程序阻塞在了writeLock.lock();这一行上。

java的ReentrantReadWriteLock不能锁升级的原因是什么

下面我们看一下WriteLock的加锁过程的部分源码:

java.util.concurrent.locks.ReentrantReadWriteLock.Sync#tryAcquire

java的ReentrantReadWriteLock不能锁升级的原因是什么

当这个tryAcquire返回false时,就跟ReentrantLock的逻辑差不多了,最后各种判断条件都会失败,最后,程序会阻塞在这里:java.util.concurrent.locks.AbstractQueuedSynchronizer#parkAndCheckInterrupt

java的ReentrantReadWriteLock不能锁升级的原因是什么

用流程图来描述一下这个问题是这样的:

java的ReentrantReadWriteLock不能锁升级的原因是什么

假如只有一个线程t1,当t1已经获取读锁之后,再次获取写锁,因为写锁在加锁时判断到当前锁已经被加过读锁读写互斥,所以写锁会等待读锁释放之后再加锁。但是因为读锁是被当前线程持有的,所以这个等待会无限的等待下去,最后就成了死锁。

“java的ReentrantReadWriteLock不能锁升级的原因是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!