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

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

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

    隨筆 - 0, 文章 - 264, 評論 - 170, 引用 - 0
    數據加載中……

    CountDownLatch的使用(注:轉載于http://www.tkk7.com/fanjs2000/archive/2012/10/31/390521.html)

    CountDownLatch如其所寫,是一個倒計數的鎖存器,當計數減至0時觸發特定的事件。利用這種特性,可以讓主線程等待子線程的結束。下面以一個模擬運動員比賽的例子加以說明。

    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;

    public class Test {
        
    private static final int PLAYER_AMOUNT = 5;

        
    public static void main(String[] args) {        
            
    //對于每位運動員,CountDownLatch減1后即結束比賽
            CountDownLatch begin = new CountDownLatch(1);
            
    //對于整個比賽,所有運動員結束后才算結束
            CountDownLatch end = new CountDownLatch(PLAYER_AMOUNT);
            Player[] plays 
    = new Player[PLAYER_AMOUNT];

            
    for (int i = 0; i < PLAYER_AMOUNT; i++)
                plays[i] 
    = new Player(i + 1, begin, end);

            
    //設置特定的線程池,大小為5
            ExecutorService exe = Executors.newFixedThreadPool(PLAYER_AMOUNT);
            
    for (Player p : plays)
                exe.execute(p); 
    //分配線程
            begin.countDown();
            System.out.println(
    "Race begins!");
            
    try {
                end.await(); 
    //等待end狀態變為0,即為比賽結束
            } catch (InterruptedException e) {
                
    // TODO: handle exception
                e.printStackTrace();
            } 
    finally {
                System.out.println(
    "Race ends!");
            }
            exe.shutdown();
        }
    }

    class Player implements Runnable {

        
    private int id;
        
    private CountDownLatch begin;
        
    private CountDownLatch end;

        
    public Player(int i, CountDownLatch begin, CountDownLatch end) {
            
    // TODO Auto-generated constructor stub
            super();
            
    this.id = i;
            
    this.begin = begin;
            
    this.end = end;
        }

        
    public void run() {
            
    // TODO Auto-generated method stub
            try {
                begin.await(); 
    //等待begin的狀態為0
                Thread.sleep((long) (Math.random() * 100)); //隨機分配時間,即運動員完成時間
                System.out.println("Play" + id + " arrived.");
            } 
    catch (InterruptedException e) {
                
    // TODO: handle exception
                e.printStackTrace();
            } 
    finally {
                end.countDown(); 
    //使end狀態減1,最終減至0
            }
        }
    }

    posted on 2012-10-31 17:19 小一敗涂地 閱讀(488) 評論(0)  編輯  收藏 所屬分類: 并發、多線程java語言相關

    主站蜘蛛池模板: 亚洲日韩国产精品无码av| 国产免费人成在线视频| 亚洲午夜久久久影院伊人| 成年女人永久免费观看片| 免费看香港一级毛片| 成熟女人牲交片免费观看视频 | 亚洲精品456人成在线| 亚洲在成人网在线看| 亚洲国产成人久久99精品| 亚洲一区无码中文字幕乱码| 亚洲AV无码乱码在线观看代蜜桃| 亚洲婷婷天堂在线综合| 亚洲色大成网站WWW国产| 九九精品国产亚洲AV日韩| 特级av毛片免费观看| sss在线观看免费高清| 成人免费一区二区三区| 3344在线看片免费| 8x8x华人永久免费视频| 国产91色综合久久免费| 女人被免费视频网站| 国产v片免费播放| 中文字幕亚洲激情| 久久久久亚洲精品成人网小说| 又粗又大又硬又爽的免费视频| 无码区日韩特区永久免费系列 | 久久成人免费电影| 久久久久久精品免费免费自慰| 在线免费观看一区二区三区| 免费国产在线观看老王影院 | 57PAO成人国产永久免费视频| 成年美女黄网站18禁免费| 国产三级免费观看| 国产亚洲精品a在线无码| 亚洲国产精品成人精品小说| 亚洲乱理伦片在线观看中字| 一级毛片免费观看不收费| 久久精品免费电影| 在线精品免费视频| 中文字幕一精品亚洲无线一区| 亚洲精品高清在线|