黑马程序员技术交流社区

标题: CyclicBarrier的使用 [打印本页]
作者: xgm    时间: 2016-3-18 00:29
标题: CyclicBarrier的使用
  1. * 目的：了解CyclicBarrier
  2. * CyclicBarrier作用：
  3. *                 一组线程相互等待，知道都到达了某个公共屏障，继续往下走。
  4. */
  5. public class CyclicBarrierTest {

  7.         public static void main(String[] args) {
  8.                
  9.                 ExecutorService threadPool = Executors.newCachedThreadPool();
  10.                 final CyclicBarrier barrier = new CyclicBarrier(3);
  11.                
  12.                 for(int i=0;i<3;i++){
  13.                         final int n = i;
  14.                         Runnable runnable = new Runnable(){
  15.                                 public void run() {
  16.                                         try {
  17.                                                 Thread.sleep(1000*n);
  18.                                                 System.out.println(Thread.currentThread().getName()+
  19.                                                                 "到达了A地点，正坐在马路上看着短裙美女等待着其他人,"+"当前已有人数"+barrier.getNumberWaiting());
  20.                                                 barrier.await();
  21.                                                
  22.                                                 Thread.sleep(1000*n);
  23.                                                 System.out.println(Thread.currentThread().getName()+
  24.                                                                 "到达了B地点，正在咖啡厅搭讪美女等待着其他人"+"当前已有人数"+barrier.getNumberWaiting());
  25.                                                 barrier.await();

  27.                                                 Thread.sleep(1000*n);
  28.                                                 System.out.println(Thread.currentThread().getName()+
  29.                                                                 "到达了C地点，正在和刚刚搭讪到的美女电话聊着天等待着其他人"+"当前已有人数"+barrier.getNumberWaiting());
  30.                                                 barrier.await();
  31.                                         } catch (InterruptedException e) {
  32.                                                 e.printStackTrace();
  33.                                         } catch (BrokenBarrierException e) {
  34.                                                 e.printStackTrace();
  35.                                         }
  36.                                 }
  37.                         };
  38.                         threadPool.execute(runnable);
  39.                 }
  40.                 threadPool.shutdown();
  41.         }
  42. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2