首页 > 其他分享 >CyclicBarrier适用场景

CyclicBarrier适用场景

时间:2022-11-08 16:23:29浏览次数:34  
标签:场景 Thread 适用 System 线程 println CyclicBarrier out

1、CyclicBarrier无法阻塞主线程,不适合在需要同步返回的接口中使用。CountDownLatch可以阻塞主线程,适用于需要同步返回的接口

2、CyclicBarrier适用于异步任务,尤其需要对子线程的执行结果做汇聚计算的更为适合

3、使用示例

    public static void main(String[] args) {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{
            //回调函数(汇聚线程),所有子线程执行到await时,会执行该回调函数.
            System.out.println("集齐7颗龙珠,召唤神龙");
        });
        for (int i = 0; i < 7; i++) {
            final int tmpInt = i + 1;
            new Thread(()->{
                System.out.println(Thread.currentThread().getName() + " 收集到第" + tmpInt + "颗龙珠!" );
                try {
                    cyclicBarrier.await();//此时子线程会阻塞住
                    System.out.println("汇聚线程已执行完成,子线程继续执行.线程:" + Thread.currentThread().getName());
                } catch (Exception e) {
                    e.printStackTrace();
                }
            },String.valueOf(i)).start();
        }
        System.out.println("我是主线程,CyclicBarrier无法阻塞我...");
    }

  

标签:场景,Thread,适用,System,线程,println,CyclicBarrier,out
From: https://www.cnblogs.com/bobobjh/p/16870108.html

相关文章