新的起點(diǎn) 新的開(kāi)始

          快樂(lè)生活 !

          深入淺出Java多線(xiàn)程(1)-方法 join

              對(duì)于Java開(kāi)發(fā)人員,多線(xiàn)程應(yīng)該是必須熟練應(yīng)用的知識(shí)點(diǎn),特別是開(kāi)發(fā)基于Java語(yǔ)言的產(chǎn)品。本文將深入淺出的表述Java多線(xiàn)程的知識(shí)點(diǎn),在后續(xù)的系列里將側(cè)重于Java5由Doug Lea教授提供的Concurrent并行包的設(shè)計(jì)思想以及具體實(shí)現(xiàn)與應(yīng)用。
              如何才能深入淺出呢,我的理解是帶著問(wèn)題,而不是泛泛的看。所以該系列基本以解決問(wèn)題為主,當(dāng)然我也非常希望讀者能夠提出更好的解決問(wèn)題的方案以及提出更多的問(wèn)題。由于水平有限,如果有什么錯(cuò)誤之處,請(qǐng)大家提出,共同討論,總之,我希望通過(guò)該系列我們能夠深入理解Java多線(xiàn)程來(lái)解決我們實(shí)際開(kāi)發(fā)的問(wèn)題。
              作為開(kāi)發(fā)人員,我想沒(méi)有必要討論多線(xiàn)程的基礎(chǔ)知識(shí),比如什么是線(xiàn)程? 如何創(chuàng)建等 ,這些知識(shí)點(diǎn)是可以通過(guò)書(shū)本和Google獲得的。本系列主要是如何理深入解多線(xiàn)程來(lái)幫助我們平時(shí)的開(kāi)發(fā),比如線(xiàn)程池如何實(shí)現(xiàn)? 如何應(yīng)用鎖等。 

          (1)方法Join是干啥用的? 簡(jiǎn)單回答,同步,如何同步? 怎么實(shí)現(xiàn)的? 下面將逐個(gè)回答。
              自從接觸Java多線(xiàn)程,一直對(duì)Join理解不了。JDK是這樣說(shuō)的:
          Thread (Java Platform SE 6)    join
              public final void join(long millis)throws InterruptedException
              Waits at most millis milliseconds for this thread to die. A timeout of 0 means to wait forever.
           大家能理解嗎? 字面意思是等待一段時(shí)間直到這個(gè)線(xiàn)程死亡,我的疑問(wèn)是那個(gè)線(xiàn)程,是它本身的線(xiàn)程還是調(diào)用它的線(xiàn)程的,上代碼: 
          package concurrentstudy;
          /**
           *
           * 
          @author vma
           
          */
          public class JoinTest {
              
          public static void main(String[] args) {
                  Thread t 
          = new Thread(new RunnableImpl());
                  t.start();
                  
          try {
                      t.join(
          1000);
                      System.out.println(
          "joinFinish");
                  } 
          catch (InterruptedException e) {
                      
          // TODO Auto-generated catch block
                      e.printStackTrace();
               
                  }
              }
          }
          class RunnableImpl implements Runnable {

              @Override
              
          public void run() {
                  
          try {
                      System.out.println(
          "Begin sleep");
                      Thread.sleep(
          1000);
                     System.out.println(
          "End sleep");
                  } 
          catch (InterruptedException e) {
                      e.printStackTrace();
                  }

              }
          }
          結(jié)果是:
          Begin sleep
          End sleep
          joinFinish
          明白了吧,當(dāng)main線(xiàn)程調(diào)用t.join時(shí),main線(xiàn)程等待t線(xiàn)程,等待時(shí)間是1000,如果t線(xiàn)程Sleep 2000呢
           public void run() {
                  
          try {
                      System.out.println(
          "Begin sleep");
                      // Thread.sleep(
          1000);
                      Thread.sleep(2000);
                     System.out.println("End sleep");
                  } 
          catch (InterruptedException e) {
                      e.printStackTrace();
                  }

              }

          結(jié)果是:
          Begin sleep
          joinFinish
          End sleep
          也就是說(shuō)main線(xiàn)程只等1000毫秒,不管T什么時(shí)候結(jié)束,如果是t.join()呢, 看代碼:  
           public final void join() throws InterruptedException {
              join(0);
              }
          就是說(shuō)如果是t.join() = t.join(0) 0 JDK這樣說(shuō)的 A timeout of 0 means to wait forever 字面意思是永遠(yuǎn)等待,是這樣嗎?
          其實(shí)是等到t結(jié)束后。
          這個(gè)是怎么實(shí)現(xiàn)的嗎? 看JDK代碼:
              /**
               * Waits at most <code>millis</code> milliseconds for this thread to 
               * die. A timeout of <code>0</code> means to wait forever. 
               *
               * 
          @param      millis   the time to wait in milliseconds.
               * 
          @exception  InterruptedException if any thread has interrupted
               *             the current thread.  The <i>interrupted status</i> of the
               *             current thread is cleared when this exception is thrown.
               
          */
              
          public final synchronized void join(long millis) 
              
          throws InterruptedException {
              
          long base = System.currentTimeMillis();
              
          long now = 0;

              
          if (millis < 0) {
                      
          throw new IllegalArgumentException("timeout value is negative");
              }

              
          if (millis == 0) {
                  
          while (isAlive()) {
                  wait(
          0);
                  }
              } 
          else {
                  
          while (isAlive()) {
                  
          long delay = millis - now;
                  
          if (delay <= 0) {
                      
          break;
                  }
                  wait(delay);
                  now 
          = System.currentTimeMillis() - base;
                  }
              }
              }
          其實(shí)Join方法實(shí)現(xiàn)是通過(guò)wait(小提示:Object 提供的方法)。 當(dāng)main線(xiàn)程調(diào)用t.join時(shí)候,main線(xiàn)程會(huì)獲得線(xiàn)程對(duì)象t的鎖(wait 意味著拿到該對(duì)象的鎖),調(diào)用該對(duì)象的wait(等待時(shí)間),直到該對(duì)象喚醒main線(xiàn)程,比如退出后。

          這就意味著main 線(xiàn)程調(diào)用t.join時(shí),必須能夠拿到線(xiàn)程t對(duì)象的鎖,如果拿不到它是無(wú)法wait的,剛開(kāi)的例子t.join(1000)不是說(shuō)明了main線(xiàn)程等待1秒,如果在它等待之前,其他線(xiàn)程獲取了t對(duì)象的鎖,它等待時(shí)間可不就是1毫秒了。上代碼介紹:
          /*
           * To change this template, choose Tools | Templates
           * and open the template in the editor.
           
          */
          package concurrentstudy;
          /**
           *
           * 
          @author vma
           
          */
          public class JoinTest {
              
          public static void main(String[] args) {
                  Thread t 
          = new Thread(new RunnableImpl());
                 
          new ThreadTest(t).start();
                  t.start();
                  
          try {
                      t.join();
                      System.out.println(
          "joinFinish");
                  } 
          catch (InterruptedException e) {
                      
          // TODO Auto-generated catch block
                      e.printStackTrace();
               
                  }
              }
          }
          class ThreadTest extends Thread {

              Thread thread;

              
          public ThreadTest(Thread thread) {
                  
          this.thread = thread;
              }

              @Override
              
          public void run() {
                  holdThreadLock();
              }

              
          public void holdThreadLock() {
                  
          synchronized (thread) {
                      System.out.println(
          "getObjectLock");
                      
          try {
                          Thread.sleep(
          9000);

                      } 
          catch (InterruptedException ex) {
                       ex.printStackTrace();
                      }
                      System.out.println(
          "ReleaseObjectLock");
                  }

              }
          }

          class RunnableImpl implements Runnable {

              @Override
              
          public void run() {
                  
          try {
                      System.out.println(
          "Begin sleep");
                      Thread.sleep(
          2000);
                     System.out.println(
          "End sleep");
                  } 
          catch (InterruptedException e) {
                      e.printStackTrace();
                  }


              }
          }
          在main方法中 通過(guò)new ThreadTest(t).start();實(shí)例化ThreadTest 線(xiàn)程對(duì)象, 它在holdThreadLock()方法中,通過(guò) synchronized (thread),獲取線(xiàn)程對(duì)象t的鎖,并Sleep(9000)后釋放,這就意味著,即使
          main方法t.join(1000),等待一秒鐘,它必須等待ThreadTest 線(xiàn)程釋放t鎖后才能進(jìn)入wait方法中,它實(shí)際等待時(shí)間是9000+1000 MS
          運(yùn)行結(jié)果是:
          getObjectLock
          Begin sleep
          End sleep
          ReleaseObjectLock
          joinFinish

          小結(jié):
          本節(jié)主要深入淺出join及JDK中的實(shí)現(xiàn)。
          在下一節(jié)中,我們將要討論SWing 中的事件方法線(xiàn)程來(lái)解決一個(gè)網(wǎng)友問(wèn)到的問(wèn)題:
          如何控制Swing程序在單機(jī)只有一個(gè)實(shí)例,也就是不能運(yùn)行第二個(gè)Main方法。





             

          posted on 2008-08-23 23:25 advincenting 閱讀(27500) 評(píng)論(13)  編輯  收藏

          評(píng)論

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2008-09-04 20:46 Brian

          學(xué)習(xí)了,我一直知道join方法的用法,但從沒(méi)想法它的實(shí)現(xiàn)。受益啊!  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2008-09-08 23:04 Xsource

          明白了····
          謝謝  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2009-02-24 22:51 小石~~

          好文章 不愧是深入淺出 拜讀  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2009-04-09 15:59 Adams

          bu cuo de   回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2009-04-21 15:45 陌生人

          看了你的文章.我測(cè)試了下,發(fā)現(xiàn)你最后一個(gè)例子中,“main方法t.join(1000),等待一秒鐘,它必須等待ThreadTest 線(xiàn)程釋放t鎖后才能進(jìn)入wait方法中,它實(shí)際等待時(shí)間是9000+1000 MS” ,它并不是如你寫(xiě)的這樣,而是ReleaseObjectLock 和joinFinish幾乎一起出現(xiàn)的。 ...


            回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2009-04-21 16:28 陌生人

          我做了個(gè)測(cè)試:public static void main(String[] args) {
          Thread t = new Thread(new RunnableImpl());
          new ThreadTest(t).start();
          // new ThreadTest(t).start();
          t.start();
          try {
          System.out.println("joinBegin?");
          t.join(50000);
          System.out.println("joinFinish");
          //t.start();
          } catch (InterruptedException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();

          }
          }
          當(dāng)只有1個(gè)new ThreadTest(t).start();的時(shí)候,不管你 t.join(50000);里面寫(xiě)多少,都是一起出現(xiàn)最后結(jié)果ReleaseObjectLock,joinFinish。但是當(dāng)你寫(xiě)了2個(gè)new ThreadTest(t).start(); 這個(gè)t.join(50000);里面數(shù)字就有關(guān)系了,它影響到了joinFinish打印的順序,但是不管你怎么寫(xiě),它都是和其中一個(gè)ReleaseObjectLock 一起出現(xiàn)..呵呵...希望我才現(xiàn)在回復(fù)這個(gè)還不嫌晚..  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join[未登錄](méi) 2011-05-26 16:49 Michael

          寫(xiě)得好,學(xué)習(xí)了  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2011-08-24 18:14 Scott Fan

          博主啊,你最后這不把我們往坑里帶嘛··

          你看啊,
          Thread的public final synchronized void join(long millis) 方法中
          有這么一個(gè)分支:
          if (millis == 0) {
          while (isAlive()) {
          wait(0);
          }
          } else {
          while (isAlive()) // 大家注意這句啊!!
          {
          long delay = millis - now;
          if (delay <= 0) {
          break;
          }
          wait(delay);
          now = System.currentTimeMillis() - base;
          }
          }

          走到 while (isAlive()) 這個(gè)循環(huán)的時(shí)候,線(xiàn)程對(duì)象的isAlive()是false啊,所以直接就返回了,
          不會(huì)像你說(shuō)的似的,9000+1000毫秒。

          大家看的時(shí)候別往坑里跳啊。  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2012-02-26 23:34 路人甲

          哥們你這篇深入淺出寫(xiě)得...最后一個(gè)程序這毛病多了去了..新手不要往坑里跳....jion的JDK很有參考意義 最后一個(gè)程序作為捉蟲(chóng)程序(邏輯錯(cuò)誤) 很有價(jià)值。。  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join 2012-02-27 00:11 路人甲

          關(guān)于最后一個(gè)程序,按照作者所寫(xiě)程序,線(xiàn)程間的運(yùn)行狀況如下所述:
          首先啟動(dòng)ThreadTest,對(duì)t加鎖(注意,加鎖的是t的代碼塊,此處對(duì)t加鎖導(dǎo)致main不能獲得t的鎖,所以t.jion無(wú)法執(zhí)行,但是不影響t線(xiàn)程本身start),然后sleep ,接著t.start(),t sleep 2秒。之后程序無(wú)事可做,再7秒之后,ThreatTest線(xiàn)程結(jié)束,鎖釋放。main獲得t的鎖,此時(shí)t線(xiàn)程已經(jīng)不是alive。所以立刻輸出jionFinish。在作者的程序中,t.jion相當(dāng)于將main的線(xiàn)程blocked.若想達(dá)到作者最后一句所說(shuō)的jion 9000+1000毫秒,則在ThreadTest釋放鎖之后,t線(xiàn)程應(yīng)該處于alive狀態(tài)。所以講RunnableImpl中的sleep時(shí)間設(shè)置為大于10000,則實(shí)際等待時(shí)間為9000+1000毫秒。但是此時(shí)的輸出順序發(fā)生變化,為:
          getObjectLock
          Begin sleep
          ReleaseObjectLock
          jionFinish
          End sleep
          希望上述解釋能夠讓大家走出作者的坑。。。另,我把這篇博文轉(zhuǎn)載到我的blog里面進(jìn)行更正了  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join[未登錄](méi) 2012-11-06 15:45 test

          最后一個(gè)運(yùn)行了一下,怎么也只有9秒啊?
          Tue Nov 06 15:44:22 CST 2012getObjectLock
          Tue Nov 06 15:44:22 CST 2012Begin sleep
          Tue Nov 06 15:44:24 CST 2012End sleep
          Tue Nov 06 15:44:31 CST 2012ReleaseObjectLock
          Tue Nov 06 15:44:31 CST 2012joinFinish  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join[未登錄](méi) 2013-04-10 14:59 eason

          @路人甲
          精彩,了解了  回復(fù)  更多評(píng)論   

          # re: 深入淺出Java多線(xiàn)程(1)-方法 join[未登錄](méi) 2013-06-21 14:51

          Begin sleep
          joinFinish
          End sleep
          我的怎么不一樣呀  回復(fù)  更多評(píng)論   


          只有注冊(cè)用戶(hù)登錄后才能發(fā)表評(píng)論。


          網(wǎng)站導(dǎo)航:
           

          公告

          Locations of visitors to this pageBlogJava
        1. 首頁(yè)
        2. 新隨筆
        3. 聯(lián)系
        4. 聚合
        5. 管理
        6. <2013年4月>
          31123456
          78910111213
          14151617181920
          21222324252627
          2829301234
          567891011

          統(tǒng)計(jì)

          常用鏈接

          留言簿(13)

          隨筆分類(lèi)(71)

          隨筆檔案(179)

          文章檔案(13)

          新聞分類(lèi)

          IT人的英語(yǔ)學(xué)習(xí)網(wǎng)站

          JAVA站點(diǎn)

          優(yōu)秀個(gè)人博客鏈接

          官網(wǎng)學(xué)習(xí)站點(diǎn)

          生活工作站點(diǎn)

          最新隨筆

          搜索

          積分與排名

          最新評(píng)論

          閱讀排行榜

          評(píng)論排行榜

          主站蜘蛛池模板: 清水县| 阳东县| 洞口县| 隆子县| 米脂县| 平谷区| 武平县| 珠海市| 土默特右旗| 苗栗县| 大悟县| 钦州市| 临泽县| 深水埗区| 桓仁| 正蓝旗| 谷城县| 怀宁县| 灌云县| 永吉县| 丰原市| 长寿区| 大方县| 忻城县| 龙门县| 如东县| 阿图什市| 从化市| 神池县| 贵阳市| 桦川县| 阳城县| 靖远县| 新丰县| 永济市| 岳西县| 博兴县| 乌苏市| 焉耆| 蛟河市| 平阴县|