1. 程式人生 > >ReentrantLock 重入鎖(下)

ReentrantLock 重入鎖(下)

cut thread new override target lan str art abstract

前沿:

ReentrantLock 是java重入鎖一種實現,在java中我們通常使用ReentrantLock 和 synchronized來實現鎖功能,本篇通過例子來理解下ReentrantLock使用以及什麽是可重入鎖。 理解可重入: 1. 鎖機制是為了多線程並發訪問共享資源情況下為保證線程的安全,和對資源的原子性操作,     舉個例子: i=i+1;其實是三部操作首先將i讀取到線程的臨時區存放,然後加一操作,最後將結果寫回去。所謂鎖機制就是保證一段程序在某段時間只有一個線程執行。 2. 可重入性當一個線程獲取鎖的時候,後來的任務還可以繼續獲取鎖,比其它線程有獲取鎖的優先性,解決問題,滿足遞歸調用依然使鎖機制有效。
舉個生活的例子: 村裏有一口井,每家都可以打水,但是,如果你正在打水的時候,你老弟來打水那麽你老弟具有優先打水資格。 簡單小程序理解可重入鎖: 1. 重復獲取鎖:
        ReentrantLock reentrantLock = new ReentrantLock();
        reentrantLock.lock();
        System.out.println("Hello World1");
        reentrantLock.lock();
        System.out.println("Hello World2");
        reentrantLock.unlock();
        reentrantLock.unlock();
結果:

Hello World1
Hello World2

 2. 釋放鎖多一次

        ReentrantLock reentrantLock = new ReentrantLock();
        reentrantLock.lock();
        System.out.println("Hello World1");
        reentrantLock.lock();
        System.out.println("Hello World2");
        reentrantLock.unlock();
        reentrantLock.unlock();
        reentrantLock.unlock();
結果:

Exception in thread "main" Hello World1
Hello World2
java.lang.IllegalMonitorStateException
at java.util.concurrent.locks.ReentrantLock$Sync.tryRelease(ReentrantLock.java:151)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.release(AbstractQueuedSynchronizer.java:1261)
at java.util.concurrent.locks.ReentrantLock.unlock(ReentrantLock.java:457)
at com.juxinli.docs.test.Main.main(Main.java:21)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140)

通過對比很明顯發現同一個線程可以重復獲取兩次鎖,但釋放三次就出現異常。

3. 多線程鎖機制

 ReentrantLock reentrantLock = new ReentrantLock();
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(100);
                    reentrantLock.lock();
                    System.out.println("Hello World1");
                    reentrantLock.unlock();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                reentrantLock.lock();
                try {
                    Thread.sleep(1000);
                    System.out.println("Hello World2");
                    reentrantLock.unlock();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();
結果:

Hello World2
Hello World1



很明顯按照逾期結果輸出。

ReentrantLock 重入鎖(下)