Java多線程之synchronized增強版——ReentrantLock

接下來介紹比synchronized功能上更豐富的關(guān)鍵字:重入鎖

  • 靈活性:

    public class ReentrantLockTest implements Runnable{
        public static ReentrantLock lock = new ReentrantLock();
        public static int flag = 0;
    
        @Override
        public void run() {
            for (int i = 0; i < 10000000; i++) {
                lock.lock();
                try {
                    flag++;
                } finally {
                    lock.unlock();
                }
            }
        }
    
        public static void main(String args[]) throws InterruptedException {
            ReentrantLockTest test = new ReentrantLockTest();
            Thread first = new Thread(test);
            Thread second = new Thread(test);
            first.start();
            second.start();
            first.join();
            second.join();
            System.out.println(flag);
        }
    }
    

    lock.lock();這里恒序,通過重入鎖保護臨界區(qū)安全,以免發(fā)生線程安全問題。

    lock.unlock();這里涧至,必須手動指示釋放鎖的操作氏仗,否則其他線程將無法獲得。

    在這段代碼里,我們能見到重入鎖靈活的特點嫩絮。但為什么叫“重入”呢婆殿?

    看下段代碼:

        @Override
        public void run() {
            for (int i = 0; i < 10000000; i++) {
                lock.lock();
                lock.lock();
                try {
                    flag++;
                } finally {
                    lock.unlock();
                    lock.unlock();
                }
            }
        }
    

    因為該鎖能反復進進出出诈乒。但要注意一下:

    在上段代碼中,鎖是可以重復獲取的婆芦。如果不允許怕磨,則該線程在第二次獲取鎖時會和自己產(chǎn)生死鎖問題。同時也要注意寞缝,線程獲取多少次鎖就要釋放多少此鎖癌压。當獲取鎖的次數(shù)大于釋放鎖的次數(shù)、相當于該線程還持有鎖荆陆。當獲取鎖的次數(shù)少于釋放鎖的次數(shù)滩届、則會得到一個java.lang.IllegalMonitorStateException異常。

  • 中斷響應:

    二話不說貼代碼:

    public class ReentrantLockTest implements Runnable{
        public static ReentrantLock producer = new ReentrantLock();
        public static ReentrantLock consumer = new ReentrantLock();
        public int flag = 0;
        public ReentrantLockTest(int flag){
            this.flag = flag;
        }
        @Override
        public void run() {
            try {
                if (flag == 0) {
                    producer.lockInterruptibly();
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {
    
                    }
                    consumer.lockInterruptibly();
                    System.out.println(Thread.currentThread().getName() + "完成工作");
                } else {
                    consumer.lockInterruptibly();
                    try {
                        Thread.sleep(500);
                    } catch (InterruptedException e) {
    
                    }
                    producer.lockInterruptibly();
                    System.out.println(Thread.currentThread().getName() + "完成工作");
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                if (producer.isHeldByCurrentThread()) {
                    producer.unlock();
                }
                if (consumer.isHeldByCurrentThread()) {
                    consumer.unlock();
                }
                System.out.println(Thread.currentThread().getName() + ": 線程退出");
            }
        }
    
        public static void main(String args[]) throws InterruptedException {
            ReentrantLockTest producerThread = new ReentrantLockTest(1);
            ReentrantLockTest consumerThread = new ReentrantLockTest(0);
            Thread first = new Thread(producerThread);
            Thread second = new Thread(consumerThread);
            first.setName("producer");
            second.setName("consumer");
            first.start();
            second.start();
            Thread.sleep(1000);
            second.interrupt();
        }
    }
    

    這是一段容易造成死鎖的代碼被啼,具體原因大家應該懂帜消。當執(zhí)行到second.interrupt();時,second線程在等待鎖時被中斷浓体,故second線程會放棄對鎖的申請泡挺、并對已持有資源進行釋放。first線程則能夠正常獲取所等待的鎖并繼續(xù)執(zhí)行下去命浴。

    結(jié)果如下:

            producer完成工作
            java.lang.InterruptedException
            consumer: 線程退出
            producer: 線程退出
            at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireInterruptibly(AbstractQueuedSynchronizer.java:898)
            at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireInterruptibly(AbstractQueuedSynchronizer.java:1222)
            at java.util.concurrent.locks.ReentrantLock.lockInterruptibly(ReentrantLock.java:335)
            at blog.ReentrantLockTest.run(ReentrantLockTest.java:22)
            at java.lang.Thread.run(Thread.java:748)
    

    真正完成工作的只有producer線程娄猫。

  • 限時等待:

    除了用中斷避免死鎖問題外,還可以用限時等待鎖來避免生闲。限時等待鎖有點像是系統(tǒng)自動完成線程中斷的感覺媳溺。先展示下限時等待鎖的使用:

    public class showWait implements Runnable {
        public static ReentrantLock lock = new ReentrantLock();
        @Override
        public void run() {
            try {
                if (lock.tryLock(5, TimeUnit.SECONDS)) {
                    Thread.sleep(6000);
                } else {
                    System.out.println(Thread.currentThread().getName() + " get lock failed");
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    
        public static void main(String args[]) {
            showWait test = new showWait();
            Thread t1 = new Thread(test);
            Thread t2 = new Thread(test);
            t1.setName("producer");
            t2.setName("consumer");
            t1.start();
            t2.start();
        }
    }
    

    上述代碼展示了lock.tryLock(5,TimeUnit.SECONDS);的使用碍讯,在這里悬蔽,該方法接收兩個參數(shù),分別是時長和計時單位捉兴。

    該方法也可以不帶參數(shù)蝎困,當不帶參數(shù)時录语,當前線程會嘗試獲取鎖,如果鎖未被其他線程占有則會申請成功并立即返回true禾乘。如果鎖被其他線程占用則立即返回false澎埠。這種方法不會引起線程等待,所以不會產(chǎn)生死鎖問題盖袭。

  • 公平鎖:

    在多大數(shù)情況下失暂,鎖的申請都是非公平性的,有時會造成線程饑餓問題鳄虱。當我們使用synchronized時產(chǎn)生的鎖是非公平性的弟塞,但我們使用ReentrantLock時可以通過構(gòu)造函數(shù)進行指定其公平性。
    public ReentrantLock(boolean fair)

    當參數(shù)為true時為公平鎖拙已,默認為非公平鎖决记。公平鎖看起來挺優(yōu)美的,但其必然要維護一個等待隊列倍踪,其性能必然會降低

  • 整理:

    • lock()
    • lockInterruptibly()
    • tryLock()
    • tryLock(long time,TimeUnit unit)
    • unlock()

    大家回顧下這幾個方法吧系宫。

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個濱河市建车,隨后出現(xiàn)的幾起案子扩借,更是在濱河造成了極大的恐慌,老刑警劉巖缤至,帶你破解...
    沈念sama閱讀 219,110評論 6 508
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件潮罪,死亡現(xiàn)場離奇詭異,居然都是意外死亡领斥,警方通過查閱死者的電腦和手機嫉到,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 93,443評論 3 395
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來月洛,“玉大人何恶,你說我怎么就攤上這事〗狼” “怎么了细层?”我有些...
    開封第一講書人閱讀 165,474評論 0 356
  • 文/不壞的土叔 我叫張陵,是天一觀的道長唬涧。 經(jīng)常有香客問我今艺,道長,這世上最難降的妖魔是什么爵卒? 我笑而不...
    開封第一講書人閱讀 58,881評論 1 295
  • 正文 為了忘掉前任,我火速辦了婚禮撵彻,結(jié)果婚禮上钓株,老公的妹妹穿的比我還像新娘实牡。我一直安慰自己,他們只是感情好轴合,可當我...
    茶點故事閱讀 67,902評論 6 392
  • 文/花漫 我一把揭開白布创坞。 她就那樣靜靜地躺著,像睡著了一般受葛。 火紅的嫁衣襯著肌膚如雪题涨。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 51,698評論 1 305
  • 那天总滩,我揣著相機與錄音纲堵,去河邊找鬼。 笑死闰渔,一個胖子當著我的面吹牛席函,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播冈涧,決...
    沈念sama閱讀 40,418評論 3 419
  • 文/蒼蘭香墨 我猛地睜開眼茂附,長吁一口氣:“原來是場噩夢啊……” “哼!你這毒婦竟也來了督弓?” 一聲冷哼從身側(cè)響起营曼,我...
    開封第一講書人閱讀 39,332評論 0 276
  • 序言:老撾萬榮一對情侶失蹤,失蹤者是張志新(化名)和其女友劉穎愚隧,沒想到半個月后蒂阱,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,796評論 1 316
  • 正文 獨居荒郊野嶺守林人離奇死亡奸攻,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 37,968評論 3 337
  • 正文 我和宋清朗相戀三年蒜危,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片睹耐。...
    茶點故事閱讀 40,110評論 1 351
  • 序言:一個原本活蹦亂跳的男人離奇死亡辐赞,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出硝训,到底是詐尸還是另有隱情响委,我是刑警寧澤,帶...
    沈念sama閱讀 35,792評論 5 346
  • 正文 年R本政府宣布窖梁,位于F島的核電站赘风,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏纵刘。R本人自食惡果不足惜邀窃,卻給世界環(huán)境...
    茶點故事閱讀 41,455評論 3 331
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望假哎。 院中可真熱鬧瞬捕,春花似錦扇单、人聲如沸力试。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,003評論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至扇救,卻和暖如春刑枝,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背迅腔。 一陣腳步聲響...
    開封第一講書人閱讀 33,130評論 1 272
  • 我被黑心中介騙來泰國打工装畅, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人钾挟。 一個月前我還...
    沈念sama閱讀 48,348評論 3 373
  • 正文 我出身青樓洁灵,卻偏偏與公主長得像,于是被迫代替她去往敵國和親掺出。 傳聞我的和親對象是個殘疾皇子徽千,可洞房花燭夜當晚...
    茶點故事閱讀 45,047評論 2 355

推薦閱讀更多精彩內(nèi)容