您好,登錄后才能下訂單哦!
讀寫鎖ReentrantReadWriteLock概述
讀寫鎖ReentrantReadWriteLock,使用它比ReentrantLock效率更高。
讀寫鎖表示兩個鎖,一個是讀操作相關的鎖,稱為共享鎖;另一個是寫操作相關的鎖,稱為排他鎖。
1、讀和讀之間不互斥,因為讀操作不會有線程安全問題
2、寫和寫之間互斥,避免一個寫操作影響另外一個寫操作,引發線程安全問題
3、讀和寫之間互斥,避免讀操作的時候寫操作修改了內容,引發線程安全問題
多個Thread可以同時進行讀取操作,但是同一時刻只允許一個Thread進行寫入操作。
讀操作和讀操作共享
請看例子
ThreadDomain44類和main方法
public class ThreadDomain44 extends ReentrantReadWriteLock { public void read() { try { readLock().lock(); System.out.println(Thread.currentThread().getName() + "獲得了讀鎖, 時間為" + 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(); } }
輸出結果如下
Thread-0獲得了讀鎖, 時間為1564018325618 Thread-1獲得了讀鎖, 時間為1564018325618
盡管加了Thread.sleep(10000);兩個線程幾乎同時執行lock()后面的方法。說明readLock().lock()允許多個線程執行并且能提高執行效率。
寫操作和寫操作互斥
請看例子
public class ThreadDomain45 extends ReentrantReadWriteLock { public void write() { try { writeLock().lock(); System.out.println(Thread.currentThread().getName() + "獲得了寫鎖, 時間為" + 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(); } }
輸出結果
Thread-1獲得了寫鎖, 時間為Tue Jul 30 11:26:21 CST 2019 Thread-0獲得了寫鎖, 時間為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() + "獲得了寫鎖, 時間為" + 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() + "獲得了讀鎖, 時間為" + 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(); } }
輸出結果如下
Thread-0獲得了讀鎖, 時間為Tue Jul 30 11:49:15 CST 2019 Thread-1獲得了寫鎖, 時間為Tue Jul 30 11:49:26 CST 2019
可以看到Thread-0獲得讀鎖執行完10s后Thread-1才獲得了寫鎖,說明讀操作和寫操作互斥。
另一種輸出結果如下
Thread-1獲得了寫鎖, 時間為Tue Jul 30 14:14:07 CST 2019 Thread-0獲得了讀鎖, 時間為Tue Jul 30 14:14:17 CST 2019
可以看到Thread-1獲得寫鎖執行完10s后Thread-0才獲得了讀鎖,說明寫操作和讀操作互斥。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。