1. * 目的：了解CyclicBarrier
   
2. * CyclicBarrier作用：
   
3. *                 一组线程相互等待，知道都到达了某个公共屏障，继续往下走。
   
4. */
   
5. public class CyclicBarrierTest {
   
6. 
   
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();
    
26. 
    
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. }
    

复制代码

1. * 目的：了解CyclicBarrier
   
2. * CyclicBarrier作用：
   
3. *                 一组线程相互等待，知道都到达了某个公共屏障，继续往下走。
   
4. */
   
5. public class CyclicBarrierTest {
   
6. 
   
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();
    
26. 
    
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. }
    

复制代码