<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://m.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語言相關

    主站蜘蛛池模板: 国产国产人免费人成免费视频 | 亚洲区小说区图片区QVOD| 亚洲日韩精品国产一区二区三区 | 亚洲欧洲国产成人综合在线观看| 亚洲精品国产第一综合99久久 | 精品特级一级毛片免费观看| 日本特黄a级高清免费大片| 国产精品亚洲va在线观看| 日韩视频免费在线| 成人精品国产亚洲欧洲| 亚洲性在线看高清h片| 一级做a免费视频观看网站| 亚洲一区二区三区在线观看精品中文| 高清永久免费观看| 亚洲成亚洲乱码一二三四区软件| 国产成人久久AV免费| 久久精品国产亚洲AV电影| 国内精自视频品线六区免费| 国产精品亚洲自在线播放页码| 好爽…又高潮了免费毛片| 亚洲AV成人一区二区三区观看| 亚洲福利精品电影在线观看| 国内精品免费久久影院| 亚洲国产精品VA在线看黑人| 18女人腿打开无遮掩免费| 精品国产成人亚洲午夜福利| 日韩亚洲精品福利| 国内精品免费视频精选在线观看| 亚洲欧洲国产经精品香蕉网| 免费国产怡红院在线观看| 国产免费一区二区三区免费视频| 亚洲天堂在线播放| 成人爱做日本视频免费| 久久精品成人免费看| wwwxxx亚洲| 国产亚洲精品岁国产微拍精品| 久草视频免费在线观看| 边摸边吃奶边做爽免费视频99| 亚洲午夜未满十八勿入| 国产精品视_精品国产免费| 久久精品免费观看|