黑马程序员技术交流社区

标题: CyclicBarrier的getNumberWaiting方法的问题？？？ [打印本页]
作者: 王竞    时间: 2014-3-27 17:32
标题: CyclicBarrier的getNumberWaiting方法的问题？？？
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() 则正确了，为什么？？？这种做法正确吗？

作者: 霍振鹏    时间: 2014-3-27 22:05
程序没错，，，不过我感觉synchronized不能加，加也没用，，，，他们各自操作各自的run方法，我感觉这样写比较好
  1. package aaaa;

  3. import java.util.Random;
  4. import java.util.concurrent.CyclicBarrier;
  5. import java.util.concurrent.ExecutorService;
  6. import java.util.concurrent.Executors;

  8. public class CyclicBarrierTest {

  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.     }

  42. }
复制代码

屡试不爽

a.png (10.2 KB, 下载次数: 7)

a.png
作者: 王竞    时间: 2014-4-3 22:45
哦，这样啊，谢谢



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