JUC_CyclicBarrier

妖狐艹你老母 2023-03-13 01:55 11阅读 0赞

*  让一组线程到达一个屏障（也可以叫同步点）时被阻塞，
 *  直到最后一个线程到达屏障时，屏障才会开门，所有
 *  被屏障拦截的线程才会继续干活。
 *  线程进入屏障通过CyclicBarrier的await()方法。

--------------------

# demo-七龙珠召唤龙珠 #

import java.util.concurrent.BrokenBarrierException;
    import java.util.concurrent.CyclicBarrier;
    
    public class CyclicBarrierDemo {
        
    
        public static void main(String[] args) {
        
            CyclicBarrier cyclicBarrier=new CyclicBarrier(7, ()->{
        
                System.out.println("召唤神龙");
            });
    
            for (int i = 1; i <=7; i++) {
        
                new Thread(()->{
        
                    System.out.println("收集"+Thread.currentThread().getName()+"颗龙珠。");
                    try {
        
                        cyclicBarrier.await();
                    } catch (InterruptedException e) {
        
                        e.printStackTrace();
                    } catch (BrokenBarrierException e) {
        
                        e.printStackTrace();
                    }
                },String.valueOf(i)).start();
            }
        }
    }

JUC_CyclicBarrier

发表评论取消回复

还没有评论，来说两句吧...

相关阅读