Java多線程 ReentrantReadWriteLock原理及實(shí)例詳解
讀寫鎖ReentrantReadWriteLock概述
讀寫鎖ReentrantReadWriteLock,使用它比ReentrantLock效率更高。
讀寫鎖表示兩個(gè)鎖,一個(gè)是讀操作相關(guān)的鎖,稱為共享鎖;另一個(gè)是寫操作相關(guān)的鎖,稱為排他鎖。
1、讀和讀之間不互斥,因?yàn)樽x操作不會(huì)有線程安全問題
2、寫和寫之間互斥,避免一個(gè)寫操作影響另外一個(gè)寫操作,引發(fā)線程安全問題
3、讀和寫之間互斥,避免讀操作的時(shí)候?qū)懖僮餍薷牧藘?nèi)容,引發(fā)線程安全問題
多個(gè)Thread可以同時(shí)進(jìn)行讀取操作,但是同一時(shí)刻只允許一個(gè)Thread進(jìn)行寫入操作。
讀操作和讀操作共享
請(qǐng)看例子
ThreadDomain44類和main方法
public class ThreadDomain44 extends ReentrantReadWriteLock
{
public void read()
{
try
{
readLock().lock();
System.out.println(Thread.currentThread().getName() + "獲得了讀鎖, 時(shí)間為" +
System.currentTimeMillis());
Thread.sleep(10000);
}
catch (InterruptedException e)
{
e.printStackTrace();
}
finally
{
readLock().unlock();
}
}
public static void main(String[] args)
{
final ThreadDomain44 td = new ThreadDomain44();
Runnable readRunnable = new Runnable()
{
public void run()
{
td.read();
}
};
Thread t0 = new Thread(readRunnable);
Thread t1 = new Thread(readRunnable);
t0.start();
t1.start();
}
}
輸出結(jié)果如下
Thread-0獲得了讀鎖, 時(shí)間為1564018325618 Thread-1獲得了讀鎖, 時(shí)間為1564018325618
盡管加了Thread.sleep(10000);兩個(gè)線程幾乎同時(shí)執(zhí)行l(wèi)ock()后面的方法。說明readLock().lock()允許多個(gè)線程執(zhí)行并且能提高執(zhí)行效率。
寫操作和寫操作互斥
請(qǐng)看例子
public class ThreadDomain45 extends ReentrantReadWriteLock {
public void write()
{
try
{
writeLock().lock();
System.out.println(Thread.currentThread().getName() + "獲得了寫鎖, 時(shí)間為" +
new Date());
Thread.sleep(10000);
}
catch (InterruptedException e)
{
e.printStackTrace();
}
finally
{
writeLock().unlock();
}
}
public static void main(String[] args)
{
final ThreadDomain45 td = new ThreadDomain45();
Runnable readRunnable = new Runnable()
{
public void run()
{
td.write();
}
};
Thread t0 = new Thread(readRunnable);
Thread t1 = new Thread(readRunnable);
t0.start();
t1.start();
}
}
輸出結(jié)果
Thread-1獲得了寫鎖, 時(shí)間為Tue Jul 30 11:26:21 CST 2019 Thread-0獲得了寫鎖, 時(shí)間為Tue Jul 30 11:26:31 CST 2019
可以看到,后獲得鎖的Thread-0等待了十秒,說明寫和寫互斥
讀操作和寫操作互斥/寫操作和讀操作互斥
例子如下
public class ThreadDomain46 extends ReentrantReadWriteLock {
public void write()
{
try
{
writeLock().lock();
System.out.println(Thread.currentThread().getName() + "獲得了寫鎖, 時(shí)間為" +
new Date());
Thread.sleep(10000);
}
catch (InterruptedException e)
{
e.printStackTrace();
}
finally
{
writeLock().unlock();
}
}
public void read()
{
try
{
readLock().lock();
System.out.println(Thread.currentThread().getName() + "獲得了讀鎖, 時(shí)間為" +
new Date());
Thread.sleep(10000);
}
catch (InterruptedException e)
{
e.printStackTrace();
}
finally
{
readLock().unlock();
}
}
public static void main(String[] args)
{
final ThreadDomain46 td = new ThreadDomain46();
Runnable readRunnable = new Runnable()
{
public void run()
{
td.read();
}
};
Runnable writeRunnable = new Runnable()
{
public void run()
{
td.write();
}
};
Thread t0 = new Thread(readRunnable);
Thread t1 = new Thread(writeRunnable);
t0.start();
t1.start();
}
}
輸出結(jié)果如下
Thread-0獲得了讀鎖, 時(shí)間為Tue Jul 30 11:49:15 CST 2019 Thread-1獲得了寫鎖, 時(shí)間為Tue Jul 30 11:49:26 CST 2019
可以看到Thread-0獲得讀鎖執(zhí)行完10s后Thread-1才獲得了寫鎖,說明讀操作和寫操作互斥。
另一種輸出結(jié)果如下
Thread-1獲得了寫鎖, 時(shí)間為Tue Jul 30 14:14:07 CST 2019 Thread-0獲得了讀鎖, 時(shí)間為Tue Jul 30 14:14:17 CST 2019
可以看到Thread-1獲得寫鎖執(zhí)行完10s后Thread-0才獲得了讀鎖,說明寫操作和讀操作互斥。
以上就是本文的全部內(nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
- java并發(fā)編程StampedLock高性能讀寫鎖詳解
- java并發(fā)編程中ReentrantLock可重入讀寫鎖
- Java并發(fā)之搞懂讀寫鎖
- Java并發(fā)編程之ReadWriteLock讀寫鎖的操作方法
- Java并發(fā)編程之重入鎖與讀寫鎖
- Java并發(fā)編程之顯示鎖ReentrantLock和ReadWriteLock讀寫鎖
- Java多線程之ReentrantReadWriteLock源碼解析
- 一文了解Java讀寫鎖ReentrantReadWriteLock的使用
- 詳解Java?ReentrantReadWriteLock讀寫鎖的原理與實(shí)現(xiàn)
- Java并發(fā)讀寫鎖ReentrantReadWriteLock 使用場(chǎng)景
相關(guān)文章
Java如何實(shí)現(xiàn)通過證書訪問Https請(qǐng)求
這篇文章主要介紹了Java如何實(shí)現(xiàn)通過證書訪問Https請(qǐng)求,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-01-01
Java開啟JMX遠(yuǎn)程監(jiān)控服務(wù)配置
這篇文章主要為大家介紹了Java開啟JMX遠(yuǎn)程監(jiān)控的服務(wù)配置,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-05-05
Java如何基于okhttp請(qǐng)求SSE接口流式返回詳解
對(duì)于流式返回,Spring Boot提供了兩種不同的方式,下面這篇文章主要給大家介紹了關(guān)于Java如何基于okhttp請(qǐng)求SSE接口流式返回的相關(guān)資料,文中通過代碼介紹的非常詳細(xì),需要的朋友可以參考下2024-03-03
MyBatis類型轉(zhuǎn)換模塊的實(shí)現(xiàn)
MyBatis是一個(gè)持久層框架ORM框架,實(shí)現(xiàn)數(shù)據(jù)庫中數(shù)據(jù)和Java對(duì)象中的屬性的雙向映射,那么不可避免的就會(huì)碰到類型轉(zhuǎn)換的問題,本文主要介紹了MyBatis類型轉(zhuǎn)換模塊的實(shí)現(xiàn),感興趣的可以了解一下2023-09-09

