少年阿賓
          
				
          那些青春的歲月
          
			          		
		
          
	
          

          

          
	
          
		
          
			
				
 
BlogJava ::
首頁(yè) ::
聯(lián)系 ::
聚合
 ::
管理

			
			
			
				

	
          
		
          
			
			
			
				 
				500 
				Posts ::
				0 Stories
				::
				135 Comments
				::
				0 Trackbacks
			
		
          
	
          

			          		
		
          
	
          

          


          

          
	
          
	
					

          
			
	
	
          
		在多線程設(shè)計(jì)中，我猜常常會(huì)遇到線程間相互等待以及某個(gè)線程等待1個(gè)或多個(gè)線程的場(chǎng)景，比如多線程精密計(jì)算和大量數(shù)據(jù)處理，這里寫(xiě)下我自己的體會(huì)和理解。 

              
          

              我想應(yīng)該有很多辦法，如果是簡(jiǎn)單的1：1關(guān)系，那么可以wait（）和notify（）解決，就像一把鎖和一把鑰匙；如果是1：N關(guān)系，這個(gè)1就需要關(guān)心N的所有狀態(tài)了，最笨的辦法是1可以去查看N當(dāng)前的狀態(tài)，輪詢?cè)儐?wèn)工作是否做完。而好點(diǎn)的辦法是N做完后主動(dòng)告訴1，然后N就會(huì)有2種選擇，要么聽(tīng)從1的命令，要么繼續(xù)干自己其他的活。
          

           
          

              用傳統(tǒng)的方法我想應(yīng)該是都能實(shí)現(xiàn)的，而JDK1.5提供了CyclicBarrier與CountDownLatch來(lái)解決了這兩個(gè)問(wèn)題，而她們的區(qū)別是：
          

              CyclicBarrier使所有線程相互等待，而CountDownLatch使一個(gè)或多個(gè)線程等待其他線程。區(qū)別類似上面藍(lán)色字體，CountDownLatch不會(huì)等待其他線程了，只要做完自己的工作就干自己的活去了，也就是run()方法里其他的任務(wù)。
          

           
          

          Example：
          

           
          

           
          

          public static void testCountDownLatch() throws InterruptedException{   
            CountDownLatch cdl          =new CountDownLatch(2);   
            ExecutorService exe          =Executors.newFixedThreadPool(2);   
                       class Bow implements  Runnable{   
              CountDownLatch cdl;   
                        public Bow(CountDownLatch cdl){   
                        this.cdl=cdl;    
              }             
                        public void run(){   
               System.out.println(          "The bow is coming");   
               System.out.println(          "kick a bow ");   
                         this.cdl.countDown();   
               System.out.println(          "do other thing");   
               }             
             }             
            exe.execute(          new Bow(cdl));   
            exe.execute(          new Bow(cdl));   
            exe.shutdown();   
            System.out.println(          "Wait");   
              cdl.await();   
              System.out.println(          "End..");   
              
           }             
            
                        public static void main(String[] args) {   
                            try {   
                      Test.testCountDownLatch();   
                  }           catch (InterruptedException e) {   
                  }             
              }            
          

           
          

          輸出的結(jié)果為：
          

           
          

          The bow is coming
          kick a bow 
          do other thing
          Wait...
          The bow is coming
          kick a bow 
          do other thing
          End..
          

           
          

          如上所說(shuō)do other thing不受影響。
          

           
          

          寫(xiě)了一個(gè)CyclicBarrier的例子：
          

           
          

          public static void testCyclicBarrier() throws InterruptedException, BrokenBarrierException{
                  CyclicBarrier barr          =new CyclicBarrier(2+1);
                  
                  ExecutorService exe          =Executors.newFixedThreadPool(2);
                             class Bow implements  Runnable{
                       CyclicBarrier barr;
                                    public Bow(CyclicBarrier barr){
                                    this.barr=barr;    
                          }
                                    public void run(){
                              System.out.println(          "The bow is coming");
                              System.out.println(          "kick a down");
                                        try {
                                  barr.await();
                              }           catch (InterruptedException e) {
                                            // TODO Auto-generated catch block
                                  e.printStackTrace();
                              }           catch (BrokenBarrierException e) {
                                            // TODO Auto-generated catch block
                                  e.printStackTrace();
                              }
                              System.out.println(          "do other thing");
                              }
                      }
                  exe.execute(          new Bow(barr));
                  exe.execute(          new Bow(barr));
                  exe.shutdown();
                  System.out.println(          "Wait");
                  barr.await();
                 System.out.println(          "End..");
              
              }


                        public static void main(String[] args) {
                            try {
                      Test.testCyclicBarrier();
                  }           catch (InterruptedException e) {
                  }
                            catch (BrokenBarrierException e) {
                  }
              }
          

           
          

          輸出結(jié)果為：
          

           
          

          Wait...
          The bow is coming
          kick a down
          The bow is coming
          kick a down
          do other thing
          End..
          do other thing
          

           
          

          總結(jié)：
          

          我們看到do other thing被阻塞了，直到最后才執(zhí)行，可見(jiàn)，柵欄和計(jì)數(shù)器的目完全不同了。向Doug Lea牛人學(xué)習(xí)：）
          

           









          在網(wǎng)上看到很多人對(duì)于CountDownLatch和CyclicBarrier的區(qū)別簡(jiǎn)單理解為CountDownLatch是一次性的，而CyclicBarrier在調(diào)用reset之后還可以繼續(xù)使用。那如果只是這么簡(jiǎn)單的話，我覺(jué)得CyclicBarrier簡(jiǎn)單命名為ResetableCountDownLatch好了，顯然不是的。
          我的理解是，要從他們的設(shè)計(jì)目的去看這兩個(gè)類。javadoc里面的描述是這樣的。 
          

          

          CountDownLatch: A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.
          

          CyclicBarrier : A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point.
          

          可能是我的英語(yǔ)不夠好吧， 我感覺(jué)從這個(gè)javadoc里面要準(zhǔn)確理解他們的差異還是不容易的。
          我的理解是
          

          CountDownLatch : 一個(gè)線程(或者多個(gè))， 等待另外N個(gè)線程完成某個(gè)事情之后才能執(zhí)行。   CyclicBarrier        : N個(gè)線程相互等待，任何一個(gè)線程完成之前，所有的線程都必須等待。
          這樣應(yīng)該就清楚一點(diǎn)了，對(duì)于CountDownLatch來(lái)說(shuō)，重點(diǎn)是那個(gè)“一個(gè)線程”, 是它在等待， 而另外那N的線程在把“某個(gè)事情”做完之后可以繼續(xù)等待，可以終止。而對(duì)于CyclicBarrier來(lái)說(shuō)，重點(diǎn)是那N個(gè)線程，他們之間任何一個(gè)沒(méi)有完成，所有的線程都必須等待。
          



          

          CountDownLatch 是計(jì)數(shù)器, 線程完成一個(gè)就記一個(gè), 就像 報(bào)數(shù)一樣, 只不過(guò)是遞減的.
          而CyclicBarrier更像一個(gè)水閘, 線程執(zhí)行就想水流, 在水閘處都會(huì)堵住, 等到水滿(線程到齊)了, 才開(kāi)始泄流.
          
	
          
	
	
          
		posted on 2013-04-28 15:37 abin 閱讀(453) 評(píng)論(0)  編輯  收藏  所屬分類: JavaMultithread 
	
          

          







          
	    
    




          








          

				

          

          




    







          
        
	




主站蜘蛛池模板：
茶陵县|
亳州市|
盐城市|
昔阳县|
三门县|
临邑县|
通榆县|
新巴尔虎右旗|
沂南县|
鲁甸县|
专栏|
公安县|
蓬安县|
疏附县|
宿迁市|
沈阳市|
温州市|
蒙阴县|
建湖县|
南宫市|
南陵县|
顺平县|
云林县|
黄平县|
西平县|
景东|
嘉峪关市|
荆门市|
呼伦贝尔市|
呼图壁县|
会理县|
朝阳县|
威宁|
寿宁县|
合水县|
佳木斯市|
贵州省|
柞水县|
寿阳县|
苏尼特左旗|
大厂|