<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    Evan's Blog

    Java, software development and others.

      BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
      28 隨筆 :: 0 文章 :: 73 評論 :: 0 Trackbacks
    第3章主要介紹了數據的同步(Data Synchronization),這一章則主要介紹線程之間的同步方法(Thread Notification),同樣包括傳統的wait-and-notify方法和JDK 1.5新推出的Condition Variable。在多線程編程中,數據同步和線程同步是兩個最基本也是最關鍵的部分。
    《Java Threads》一書中通過考察打字程序中當按下start和stop按鈕后,每次都創建兩個新的線程的效率問題來引入線程同步的概念,當然不是線程同步的主要用處。不過,教科書歸教科書,實際運用則又是另一回事。所以,通過書本學習語法,通過實踐來獲得運用經驗。

    4.1 Wait and Notify

    1. 等待/喚醒類似于Solaris或POSIX中的條件變量(conditon variables),或者Windows中的事件變量(evant variable)或者信號量(signal),用于某個/多個線程暫停等待某個條件的滿足,而該條件將由其它線程來設置的情況。
    2. 在Java中,就像每個對象有一個鎖之外,任何對象都可以提供等待/喚醒的機制。就像Java中的synchronized總是表示獲得某個具體對象的鎖一樣,wait和notify也總是等待某個具體的對象,并由該對象喚醒;同樣,獲得某個對象上的鎖不一定是該對象需要同步一樣,等待和喚醒的條件也不一定是與之綁定的對象。
    3. Java中wait-and-notify的幾個方法:
    void wait(): 使當前線程處于等待狀態,直到其它線程調用了nofity()或者notifyAll()方法為止。
    void wait(long timeout): 使當前線程處于等待狀態,直到其它線程調用了nofity()或者notifyAll()方法,或者超過了指定的時間(單位為ms)為止
    void wait(long timeout, int nanos):與wait(long)一樣,只是在某些JVM中可以精確到奈秒。
    void notify(): 喚醒一個正在等待該對象的線程。
    void notifyAll(): 喚醒所有正在等待該對象的線程。
    注意:任何等待和喚醒方法都必須在與之對應的對象的同步方法或同步塊里調用。即:wait-and-notify必須和與之對應的synchronized關鍵詞一起使用的。
    4. wait()和sleep()的主要區別:
      1) sleep()可以在任何地方調用,而wait()需要在同步方法或同步塊中調用;
      2) 進入wait()函數時,JVM會自動釋放鎖,而當從wait()返回即被喚醒時,又會自動獲得鎖;而sleep()沒有這個功能,因此如果在wait()的地方用sleep()代替,則會導致相應的nofity()方法在等待時不可能被觸發,因為notify()必須在相應的同步方法或同步塊中,而此時這個鎖卻被sleep()所在的方法占用。也就是說,wait-and-notify不可能與sleep()同時使用。

    4.1.1 The Wait-and-Notify Mechanism and Synchronization
    1. 這一節詳細的講解了wait-and-notify機制和synchronized的關系,主要是兩點:1)wait-and-notify必須和synchronized同時使用;2)wait()會自動釋放和獲取鎖;
    2. 這一節中舉了一個例子用來解釋可能存在當條件被不滿足時也有可能被喚醒的情況:
      1) 線程T1調用一個同步方法;
      2) T1檢測狀態變量,發現其不滿足條件;
      3) T1調用wait(),并釋放鎖;
      4) 線程T2調用另外一個同步方法,獲得鎖;
      5) 線程T3調用另外一個同步方法,由于T2獲得了鎖,所以處于等待狀態;
      6) T2修改狀態變量,使其滿足條件,并調用notify()方法;
      7) T3獲得鎖,然后處理數據,并將狀態變量又設置為不滿足條件的狀態;
      8) T3處理完畢返回;
      9) T1被喚醒,但實際上此時條件并不滿足。
    這個例子剛好印證了《Effective Java》中"Item 50: Never invoke wait outside a loop"和《Practical Java》中"實踐54:針對wait()和notifyAll()使用旋鎖(spin locks)"。即總是用下面這種方式來調用wait():
        synchronized(obj) {
    while(<condition does not hold>)
    wait();
    
    ... // Perform action appropriate to condition }
    或者象《Practical Java》中一樣:
        synchronized(obj) {
    while(<condition does not hold>) {
    try {
    wait();
    } catch (InterruptedException e) {}
    }

    ... // Perform action appropriate to condition }
    3. 調用wait()的線程T可能在以下幾種情況被喚醒:
      1) 其它線程調用了notify(),而剛好線程T得到了通知;
      2) 其它線程調用了notifyAll();
      3) 其它線程中斷了線程T;
      4) 由于JVM的原因,導致了spurious wakeup。

    4.1.2 wait(), notify(), and notifyAll()
    1. 正像多個線程等待同一對象上的鎖,當鎖釋放時,無法確定哪個線程會得到那個鎖一樣;當有多個線程在wait()時,當另外一個線程調用nofity()的時候,也不能確定哪個線程會被喚醒; 2. 因此在《Practical Java》的"實踐53:優先使用notifyAll()而非notify()"建議的一樣,結合實踐54,可以比較好的解決線程喚醒的問題。

    4.1.3 Wait-and-Notify Mechanism with Synchronized blocks
    再次強調必須在同一個對象的synchronized方法或塊內調用該對象上的wait和notify方法。

    4.2 Condition Variables

    1. 就像上面反復強調的一樣,wait-and-notify機制是與特定對象及其上的鎖是綁定在一起的,鎖和喚醒對象不能分開,這在某些情況下不是很方便;
    2. JDK 1.5提供Condition接口來提供與其它系統幾乎一致的condition variables機制;
    3. Condition對象由Lock對象的newCondition()方法生成,從而允許一個鎖產生多個條件變量,可以根據實際情況來等待不同條件;
    4. 該書的例子沒有什么特別的實際意義,但JDK 1.5文檔中提供了一個例子,能充分說明使用Condition Variables使得程序更加清晰易讀,也更有效率:
    class BoundedBuffer {
    final Lock lock = new ReentrantLock();
    final Condition notFull = lock.newCondition();
    final Condition notEmpty = lock.newCondition(); final Object[] items = new Object[100]; int putptr, takeptr, count;

    public void put(Object x) throws InterruptedException {
    lock.lock();
    try {
    while (count == items.length)
    notFull.await();
    items[putptr] = x;
    if (++putptr == items.length) putptr = 0;
    ++count;
    notEmpty.signal();
    } finally {
    lock.unlock();
    }
    }
    public Object take() throws InterruptedException {
    lock.lock();
    try {
    while (count == 0)
    notEmpty.await();
    Object x = items[takeptr];
    if (++takeptr == items.length) takeptr = 0;
    --count;
    notFull.signal();
    return x;
    } finally {
    lock.unlock();
    }
    }
    }
    具體的說明請參考JDK 1.5的文檔。
    5. 除了用lock和await-and-signal來代替synchronized和wait-and-notify外,其語義和機制基本一樣。await()在進入前也會自動釋放鎖,然后再返回前重新獲得鎖;
    6. 使用Condition Variables的原因:
      1) 如果使用Lock對象,則必須使用condition variables;
      2) 每個Lock對象可以創建多個condition variable.
    posted on 2006-03-06 22:21 Evan 閱讀(832) 評論(0)  編輯  收藏 所屬分類: Java筆記
    主站蜘蛛池模板: 免费无遮挡无遮羞在线看| 亚洲免费一区二区| 亚洲综合激情视频| 日本中文字幕免费高清视频| 久久精品亚洲男人的天堂| 男人扒开添女人下部免费视频| 国产精品久久久久影院免费| 噜噜综合亚洲AV中文无码| 国产又大又粗又硬又长免费 | 真实乱视频国产免费观看| 亚洲婷婷综合色高清在线| 日本最新免费网站| 歪歪漫画在线观看官网免费阅读 | 国产99久久久国产精免费| 国产午夜亚洲不卡| 无码人妻一区二区三区免费n鬼沢 无码人妻一区二区三区免费看 | 亚洲午夜福利在线视频| 日韩在线看片免费人成视频播放| 亚洲AV无码一区二区三区久久精品 | 免费大香伊蕉在人线国产| 久久噜噜噜久久亚洲va久| 97在线视频免费| 亚洲国产精品一区二区第一页 | 一级特黄aa毛片免费观看| 亚洲国产福利精品一区二区| 中文字幕在线免费看线人| 青青青国产色视频在线观看国产亚洲欧洲国产综合| 亚洲精品无码av片| 成人毛片18女人毛片免费视频未| 亚洲第一成年免费网站| 国产亚洲精品看片在线观看| 5g影院5g天天爽永久免费影院| 亚洲成av人片在线天堂无| 久久精品亚洲男人的天堂| 亚洲高清视频免费| 国产精品亚洲综合天堂夜夜| 日韩高清免费观看| 两性色午夜视频免费播放| 亚洲国产模特在线播放| 亚洲国产电影av在线网址| 3d动漫精品啪啪一区二区免费|