public class CyclicBarrierTest {

    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        final CyclicBarrier cb = new CyclicBarrier(5);
        for(int i = 0; i < 5; i++) {
            Runnable runnable = new Runnable() {
                @Override
                public void run() {
                    try {
                        Thread.sleep(3 * 1000);
                                                           //为什么cb.getNumberWaiting()方法得到等待的线程的数据不正确呢？？？？
                        System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点1，当前已有" + (cb.getNumberWaiting() + 1) + "已经到达，" + (cb.getNumberWaiting() == 4 ? "都到齐了，继续走吧" : "正在等待"));
                        cb.await();
                        
                        Thread.sleep(3 * 1000);
                        System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点2，当前已有" + (cb.getNumberWaiting() + 1) + "已经到达，" + (cb.getNumberWaiting() == 4 ? "都到齐了，继续走吧" : "正在等待"));
                        cb.await();
                        
                        Thread.sleep(3 * 1000);
                        System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点3，当前已有" + (cb.getNumberWaiting() + 1) + "已经到达，" + (cb.getNumberWaiting() == 4 ? "都到齐了，继续走吧" : "正在等待"));
                        cb.await();
                        
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            };
            service.execute(runnable);
        }
        service.shutdown();
    }

}


打印结果：
线程pool-1-thread-4即将到达集合地点1，当前已有1已经到达，正在等待
线程pool-1-thread-5即将到达集合地点1，当前已有2已经到达，正在等待
线程pool-1-thread-1即将到达集合地点1，当前已有3已经到达，正在等待
线程pool-1-thread-3即将到达集合地点1，当前已有1已经到达，正在等待
线程pool-1-thread-2即将到达集合地点1，当前已有1已经到达，正在等待
线程pool-1-thread-2即将到达集合地点2，当前已有1已经到达，正在等待
线程pool-1-thread-3即将到达集合地点2，当前已有2已经到达，正在等待
线程pool-1-thread-4即将到达集合地点2，当前已有3已经到达，正在等待
线程pool-1-thread-5即将到达集合地点2，当前已有4已经到达，正在等待
线程pool-1-thread-1即将到达集合地点2，当前已有5已经到达，都到齐了，继续走吧
线程pool-1-thread-2即将到达集合地点3，当前已有1已经到达，正在等待
线程pool-1-thread-5即将到达集合地点3，当前已有1已经到达，正在等待
线程pool-1-thread-4即将到达集合地点3，当前已有1已经到达，正在等待
线程pool-1-thread-1即将到达集合地点3，当前已有1已经到达，正在等待
线程pool-1-thread-3即将到达集合地点3，当前已有4已经到达，都到齐了，继续走吧


我把run方法改为public synchronized void run() 则正确了，为什么？？？这种做法正确吗？

程序没错，，，不过我感觉synchronized不能加，加也没用，，，，他们各自操作各自的run方法，我感觉这样写比较好

1. package aaaa;
   
2. 
   
3. import java.util.Random;
   
4. import java.util.concurrent.CyclicBarrier;
   
5. import java.util.concurrent.ExecutorService;
   
6. import java.util.concurrent.Executors;
   
7. 
   
8. public class CyclicBarrierTest {
   
9. 
   
10.     public static void main(String[] args) {
    
11.         ExecutorService service = Executors.newCachedThreadPool();
    
12.         final CyclicBarrier cb = new CyclicBarrier(5);
    
13.         for(int i = 0; i < 5; i++) {
    
14.             Runnable runnable = new Runnable() {
    
15.                 @Override
    
16.                 public  void run() {
    
17.                     try {
    
18.                         Thread.sleep(new Random().nextInt(1000));
    
19.                                                            //为什么cb.getNumberWaiting()方法得到等待的线程的数据不正确呢？？？？
    
20.                         System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点1，当前已有" + (cb.getNumberWaiting() ) + "已经到达，" + (cb.getNumberWaiting() == 4 ? "都到齐了，继续走吧" : "正在等待"));
    
21.                         cb.await();
    
22.                         
    
23.                         Thread.sleep(new Random().nextInt(1000));
    
24.                         System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点2，当前已有" + (cb.getNumberWaiting() ) + "已经到达，" + (cb.getNumberWaiting() == 4 ? "都到齐了，继续走吧" : "正在等待"));
    
25.                         cb.await();
    
26.                         
    
27.                         Thread.sleep(new Random().nextInt(1000));
    
28.                         System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点3，当前已有" + (cb.getNumberWaiting() ) + "已经到达，" + (cb.getNumberWaiting() == 4 ? "都到齐了，继续走吧" : "正在等待"));
    
29.                         cb.await();
    
30.                         
    
31.                     } catch (Exception e) {
    
32.                         e.printStackTrace();
    
33.                     }
    
34.                 }
    
35.                
    
36.             };
    
37.             service.execute(runnable);
    
38.         }
    
39.         service.shutdown();
    
40.     }
    
41. 
    
42. }

复制代码

屡试不爽

哦，这样啊，谢谢