愛睡覺的程序員

            BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理 ::
            5 隨筆 :: 0 文章 :: 0 評論 :: 0 Trackbacks
               CyclicBarrier,讓多線程齊步走。讓多個線程到達某一個點之后,再同時往下運行。
              思考這樣一個案例:兩個工人從兩端挖掘隧道,各自獨立奮戰,中間不溝通,如果兩人在匯合點處碰頭了,則表明隧道已經挖通。這描繪的也是在多線程編程中,兩個線程獨立運行,在沒有線程間通信的情況下,如何解決兩個線程匯集在同一原點的問題。Java提供了CyclicBarrier(關卡,也有翻譯為柵欄)工具類來實現。
              代碼如下:
            1 import java.util.Random;
           2 import java.util.concurrent.CyclicBarrier;
           3 import java.util.concurrent.TimeUnit;
           4 
           5 public class CyclicBarrierTest {
           6     public static void main(String[] args) {
           7         // 設置匯集數量,以及匯集完成后的任務
           8         CyclicBarrier cb = new CyclicBarrier(2, new Runnable() {
           9             public void run() {
          10                 System.out.println("隧道已經打通!");
          11             }
          12         });
          13         // 工人1挖隧道
          14         new Thread(new Worker(cb), "工人1").start();
          15         // 工人2挖隧道
          16         new Thread(new Worker(cb), "工人2").start();
          17     }
          18 
          19 
          20     static class Worker implements Runnable {
          21         // 關卡
          22         private CyclicBarrier cb;
          23 
          24         public Worker(CyclicBarrier _cb) {
          25             cb = _cb;
          26         }
          27 
          28         public void run() {
          29             try {
          30                 TimeUnit.SECONDS.sleep(new Random().nextInt(10));
          31                 System.out.println(Thread.currentThread().getName() + "-到達匯合點");
          32                 // 到達匯合點
          33                 cb.await();
          34             } catch (Exception e) {
          35                 // 異常處理
          36             }
          37         }
          38     }
          39 }
          40 
          posted on 2015-02-27 11:50 polang 閱讀(246) 評論(0)  編輯  收藏

          只有注冊用戶登錄后才能發表評論。


          網站導航:
           
          主站蜘蛛池模板: 新沂市| 玉山县| 海门市| 高青县| 牡丹江市| 徐汇区| 山丹县| 盐池县| 三穗县| 湖南省| 华阴市| 南平市| 洪湖市| 阳朔县| 罗定市| 分宜县| 天台县| 阿克陶县| 旬阳县| 郸城县| 金华市| 兰西县| 庆阳市| 郑州市| 萝北县| 西盟| 东源县| 松原市| 东乌珠穆沁旗| 西平县| 深水埗区| 巨野县| 石渠县| 侯马市| 平和县| 资兴市| 虞城县| 宁陵县| 南丹县| 临武县| 西林县|