看似读锁按部就班
概述
本文簡(jiǎn)易介紹下讀寫(xiě)鎖的策略
1.在公平鎖的條件下,所有的鎖都不允許插隊(duì)
2.在非公平的條件下:
寫(xiě)鎖是可以插隊(duì)的(寫(xiě)鎖插隊(duì)可以避免饑餓)
讀鎖僅在等待隊(duì)列頭結(jié)點(diǎn)不是想獲取寫(xiě)鎖的線程的時(shí)候是可以插隊(duì)的。?
接下來(lái)我會(huì)從ReentrantReadWriteLock源碼部分進(jìn)行說(shuō)明。
公平鎖的條件下讀寫(xiě)鎖的策略
我們從ReentrantReadWriteLock 的FairLock中查看策略,如下圖所示。
從紅圈是可以看到讀鎖和寫(xiě)鎖的阻塞條件都是當(dāng)隊(duì)列中有等待的處理任務(wù)。即就是讀鎖和寫(xiě)鎖是不可以插隊(duì)的。
非公平鎖的情況下的讀寫(xiě)策略
下面我們介紹非公平鎖的情況下,寫(xiě)鎖是可以插隊(duì),讀鎖只有在頭結(jié)點(diǎn)不是寫(xiě)線程的情況是可以插隊(duì),見(jiàn)下圖所示。
讀寫(xiě)鎖測(cè)試實(shí)例代碼
下文從實(shí)例代碼來(lái)說(shuō)明讀寫(xiě)的插隊(duì)策略問(wèn)題
代碼是實(shí)現(xiàn)結(jié)果為:非公平鎖的條件下,線程1讀,線程2讀,線程3寫(xiě),線程4讀,執(zhí)行結(jié)果為線程4在線程3之后
非公平條件下讀鎖插隊(duì)代碼
下文代碼演示非公平的條件下,讀鎖進(jìn)行插隊(duì)的實(shí)現(xiàn),見(jiàn)下代碼。
非公平條件下,讀鎖插隊(duì)的條件是:當(dāng)頭結(jié)點(diǎn)不是寫(xiě)鎖時(shí),可以插隊(duì)。
import java.util.concurrent.locks.ReentrantReadWriteLock;/*** 本實(shí)例演示非公平的條件下,讀鎖插隊(duì)的問(wèn)題(當(dāng)頭結(jié)點(diǎn)不是寫(xiě)線程的時(shí)候)*/ public class NoFairReadWriteDemo {private static ReentrantReadWriteLock reentrantReadWriteLock=new ReentrantReadWriteLock(false);private static ReentrantReadWriteLock.ReadLock readLock=reentrantReadWriteLock.readLock();private static ReentrantReadWriteLock.WriteLock writeLock=reentrantReadWriteLock.writeLock();public void read(){System.out.println(Thread.currentThread().getName()+"嘗試獲取讀鎖");readLock.lock();try{System.out.println(Thread.currentThread().getName()+"獲取到了讀鎖");}finally {readLock.unlock();}}public void write(){System.out.println(Thread.currentThread().getName()+"嘗試獲取寫(xiě)鎖");writeLock.lock();try{Thread.sleep(20);System.out.println(Thread.currentThread().getName()+"獲取到了寫(xiě)鎖");} catch (InterruptedException e) {e.printStackTrace();} finally {writeLock.unlock();}}/*** 線程1獲取寫(xiě)鎖,其他線程嘗試獲取* 線程1釋放后,隊(duì)列頭為線程2,進(jìn)行讀;線程3也進(jìn)行讀,測(cè)試:線程2在讀取的時(shí)候,子線程能否插隊(duì)成功* @param args*/public static void main(String[] args) {NoFairReadWriteDemo noFairReadWriteDemo=new NoFairReadWriteDemo();new Thread(()->noFairReadWriteDemo.write(),"線程1").start();new Thread(()->noFairReadWriteDemo.read(),"線程2").start();new Thread(()->noFairReadWriteDemo.read(),"線程3").start();new Thread(()->noFairReadWriteDemo.write(),"線程4").start();new Thread(()->noFairReadWriteDemo.read(),"線程6").start();new Thread(() -> {Thread[] threads=new Thread[1000];for (int i = 0; i < 1000; i++) {int finalI = i;threads[i]=new Thread(()->noFairReadWriteDemo.read(),"子線程"+ finalI);}for (int i = 0; i < 1000; i++) {threads[i].start();}}, "線程6").start();}}?
總結(jié)
- 上一篇: 深入理解交互思想
- 下一篇: 读写锁的由奢入俭“易”