快捷導(dǎo)航

java多線程之CyclicBarrier的使用方法

更新時(shí)間：2017年10月24日 15:55:09 作者：chuyouyinghe

這篇文章主要介紹了java多線程之CyclicBarrier的使用方法的相關(guān)資料,希望通過(guò)本文能幫助到大家，讓大家理解掌握這部分內(nèi)容，需要的朋友可以參考下

java多線程之CyclicBarrier的使用方法

public class CyclicBarrierTest { 
 
  public static void main(String[] args) { 
    ExecutorService service = Executors.newCachedThreadPool(); 
    final CyclicBarrier cb = new CyclicBarrier(3); 
    for(int i=0;i<3;i++){ 
      Runnable runnable = new Runnable(){ 
          public void run(){ 
          try { 
            Thread.sleep((long)(Math.random()*10000));  
            System.out.println("線程" + Thread.currentThread().getName() +  
                "即將到達(dá)集合地點(diǎn)1，當(dāng)前已有" + (cb.getNumberWaiting()+1) + "個(gè)已經(jīng)到達(dá)，" + (cb.getNumberWaiting()==2?"都到齊了，繼續(xù)走啊":"正在等候"));             
            cb.await(); 
             
            Thread.sleep((long)(Math.random()*10000));  
            System.out.println("線程" + Thread.currentThread().getName() +  
                "即將到達(dá)集合地點(diǎn)2，當(dāng)前已有" + (cb.getNumberWaiting()+1) + "個(gè)已經(jīng)到達(dá)，" + (cb.getNumberWaiting()==2?"都到齊了，繼續(xù)走啊":"正在等候")); 
            cb.await();  
            Thread.sleep((long)(Math.random()*10000));  
            System.out.println("線程" + Thread.currentThread().getName() +  
                "即將到達(dá)集合地點(diǎn)3，當(dāng)前已有" + (cb.getNumberWaiting() + 1) + "個(gè)已經(jīng)到達(dá)，" + (cb.getNumberWaiting()==2?"都到齊了，繼續(xù)走啊":"正在等候"));            
            cb.await();            
          } catch (Exception e) { 
            e.printStackTrace(); 
          }         
        } 
      }; 
      service.execute(runnable); 
    } 
    service.shutdown(); 
  } 
}

運(yùn)行結(jié)果如下：

線程pool-1-thread-3即將到達(dá)集合地點(diǎn)1，當(dāng)前已有1個(gè)已經(jīng)到達(dá)，正在等候
線程pool-1-thread-1即將到達(dá)集合地點(diǎn)1，當(dāng)前已有2個(gè)已經(jīng)到達(dá)，正在等候
線程pool-1-thread-2即將到達(dá)集合地點(diǎn)1，當(dāng)前已有3個(gè)已經(jīng)到達(dá)，都到齊了，繼續(xù)走啊
線程pool-1-thread-3即將到達(dá)集合地點(diǎn)2，當(dāng)前已有1個(gè)已經(jīng)到達(dá)，正在等候
線程pool-1-thread-1即將到達(dá)集合地點(diǎn)2，當(dāng)前已有2個(gè)已經(jīng)到達(dá)，正在等候
線程pool-1-thread-2即將到達(dá)集合地點(diǎn)2，當(dāng)前已有3個(gè)已經(jīng)到達(dá)，都到齊了，繼續(xù)走啊
線程pool-1-thread-1即將到達(dá)集合地點(diǎn)3，當(dāng)前已有1個(gè)已經(jīng)到達(dá)，正在等候
線程pool-1-thread-3即將到達(dá)集合地點(diǎn)3，當(dāng)前已有2個(gè)已經(jīng)到達(dá)，正在等候
線程pool-1-thread-2即將到達(dá)集合地點(diǎn)3，當(dāng)前已有3個(gè)已經(jīng)到達(dá)，都到齊了，繼續(xù)走啊

如有疑問(wèn)請(qǐng)留言或者到本站社區(qū)交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對(duì)本站的支持！

您可能感興趣的文章: