同步器2-CyclicBarrier可循环障碍物

男娘i 2022-03-25 06:45 153阅读 0赞

### 场景 ###

1.  公司聚餐,全部到齐后才可以吃饭(同步),假如人员没有到齐,先到的同事需要等待(阻塞)
2.  全部人员到齐后,先拍照留念,在吃饭
3.  其他应用场景:多线程计算之后合并结果

### 实现 ###

1.  第一种构造方法

import java.util.concurrent.BrokenBarrierException;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class CyclicBarrierDemo { 
    
        public static void main(String[] args){ 
            //使用线程池
            ExecutorService threadPool = Executors.newCachedThreadPool();
            //当前5个人聚餐
            final int people = 5;
            final CyclicBarrier cyclicBarrier = new CyclicBarrier(people);//同步点,多少个线程到达后进一步执行
            for (int i = 0; i < people; i++) { 
                int userNum = i + 1;
                Runnable runnable = new Runnable() { 
                    @Override
                    public void run() { 
                        try { 
                            //模拟进入聚餐地点时间不同
                            Thread.sleep((long)(Math.random()*1000));
                            System.out.println("同事["+userNum+"]已经到达聚餐地点,当前已经有"+(cyclicBarrier.getNumberWaiting()+1)+"位同事");
                            //到达后阻塞
                            cyclicBarrier.await();
                            System.out.println("人员全部到齐开始吃饭");
                        } catch (InterruptedException | BrokenBarrierException e) { 
                            e.printStackTrace();
                        }
                    }
                };
                threadPool.execute(runnable);
            }
            threadPool.shutdown();
    
        }
    }

运行结果

同事[3]已经到达聚餐地点,当前已经有1位同事
    同事[1]已经到达聚餐地点,当前已经有2位同事
    同事[4]已经到达聚餐地点,当前已经有3位同事
    同事[2]已经到达聚餐地点,当前已经有4位同事
    同事[5]已经到达聚餐地点,当前已经有5位同事
    人员全部到齐开始吃饭
    人员全部到齐开始吃饭
    人员全部到齐开始吃饭
    人员全部到齐开始吃饭
    人员全部到齐开始吃饭

1.  第二种构造

package com.zjy.thread;
    
    import java.util.concurrent.BrokenBarrierException;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class CyclicBarrierDemo { 
    
        public static void main(String[] args){ 
            //使用线程池
            ExecutorService threadPool = Executors.newCachedThreadPool();
            //当前5个人聚餐
            final int people = 5;
            //到达同步点个数后,先执行这个Runable,再继续运行程序
            final CyclicBarrier cyclicBarrier = new CyclicBarrier(people, new Runnable() { 
                @Override
                public void run() { 
                    System.out.println("人员到齐,开始拍照留念");
                    try { 
                        Thread.sleep((long)(Math.random()*1000));
                    } catch (InterruptedException e) { 
                        e.printStackTrace();
                    }
                }
            });
            for (int i = 0; i < people; i++) { 
                int userNum = i + 1;
                Runnable runnable = new Runnable() { 
                    @Override
                    public void run() { 
                        try { 
                            //模拟进入聚餐地点时间不同
                            Thread.sleep((long)(Math.random()*1000));
                            System.out.println("同事["+userNum+"]已经到达聚餐地点,当前已经有"+(cyclicBarrier.getNumberWaiting()+1)+"位同事");
                            //到达后阻塞
                            cyclicBarrier.await();
                            if (userNum == 1){ 
                                System.out.println("拍照结束,开始吃饭");
                            }
                        } catch (InterruptedException | BrokenBarrierException e) { 
                            e.printStackTrace();
                        }
                    }
                };
                threadPool.execute(runnable);
            }
            threadPool.shutdown();
    
        }
    }

运行结果

同事[5]已经到达聚餐地点,当前已经有1位同事
    同事[3]已经到达聚餐地点,当前已经有2位同事
    同事[4]已经到达聚餐地点,当前已经有3位同事
    同事[1]已经到达聚餐地点,当前已经有4位同事
    同事[2]已经到达聚餐地点,当前已经有5位同事
    人员到齐,开始拍照留念
    拍照结束,开始吃饭