多线程－CyclicBarrier

谁借莪１个温暖的怀抱￠ 2022-07-15 00:20 240阅读 0赞

package cn.stu;
    
    import java.util.concurrent.BrokenBarrierException;
    import java.util.concurrent.CyclicBarrier;
    
    public class Worker implements Runnable{
    	
    	private CyclicBarrier cb; 
    	
    	public Worker(CyclicBarrier cb){
    		this.cb = cb;
    	}
    
    	@Override
    	public void run() {
    		try {
    			System.out.println("人员还没到期");
    			cb.await();
    			System.out.println("开始开工了..............");
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		} catch (BrokenBarrierException e) {
    			e.printStackTrace();
    		} 
    	}
    	 
    }

package cn.stu;
    
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    /***
     * 
           这个类， 只有线程数到指定的数， 这里是设置为4，  然后所有等待的线程就开始激活了，  这里表现是一个递增， 
       CountDownLatch 这个表示的是递减。 
       
          作用都是到了一个点，就全部触发型处理的模式。
    *
     */
    public class Main {
    
    	public static void main(String[] args) {
    		  
    		CyclicBarrier  cb = new CyclicBarrier(4, new Runnable() {
    			
    			@Override
    			public void run() {
    				 
    				System.out.println("已经到触发点了， 可以动工了......");
    				
    			}
    		});
    		
    		ExecutorService  exec = Executors.newFixedThreadPool(6); // 这个数不能比4小， 小的话，线程都是挂起了，永远激活不了了。
    		Worker worker = new Worker(cb);
    		for(int i = 0; i<4; i++){
    			exec.submit(worker); // 这个方法启动只会调用一条线程。
    		}
    		exec.shutdown();  
    	}
    
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，240人围观）

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

相关阅读

相关 Java多线程CyclicBarrier学习

*Java多线程CyclicBarrier学习** CyclicBarrier是多线程并发控制实用工具 * CyclicBarrier初始...

喜欢ヅ旅行/ 2024年04月20日 08:56/ 0 赞/ 32 阅读

相关 CyclicBarrier线程同步

> 关于作者： CSDN内容合伙人、技术专家，从零开始做日活千万级APP，带领团队单日营收超千万。 > 专注于分享各领域原创系列文章，擅长java后端、移动开发、商业化

朱雀/ 2024年02月21日 03:18/ 0 赞/ 63 阅读

相关【多线程】CyclicBarrier工具

文章目录介绍 1.构造方法如下所示 2.public int await()方法 3.重复使用之Reset 4.使用CoundownLat

心已赠人/ 2022年12月14日 13:55/ 0 赞/ 190 阅读

相关多线程－CyclicBarrier

package cn.stu; import java.util.concurrent.BrokenBarrierException;

本是古典何须时尚/ 2022年07月15日 00:20/ 0 赞/ 232 阅读

相关多线程－CyclicBarrier

package cn.stu; import java.util.concurrent.BrokenBarrierException;

谁借莪１个温暖的怀抱￠/ 2022年07月15日 00:20/ 0 赞/ 241 阅读

相关 java多线程之CyclicBarrier

一、简介 CyclicBarrier也是一个同步辅助类，作用和CountDownLatch几乎一模一样，并没有多大区别，CyclicBarrier是向上记数，CountD

秒速五厘米/ 2022年05月29日 00:12/ 0 赞/ 259 阅读

相关 java多线程之CyclicBarrier

CyclicBarrier是一个同步的辅助类，允许一组线程相互之间等待，达到一个共同点，再继续执行。优点：可重用；应用场景：多个线程达到一致条件后继续执行。示例

深藏阁楼爱情的钟/ 2022年05月17日 13:24/ 0 赞/ 240 阅读

相关多线程之CountDownLatch和CyclicBarrier

一、倒计时CountDownLatch CountDownLatch是一个非常实用的多线程控制工具类，称之为“倒计时器”，它允许一个或多个线程一直等待，直到其他线程的操作

╰+攻爆jí腚メ/ 2022年05月14日 00:20/ 0 赞/ 280 阅读

相关 java多线程-CyclicBarrier

主要成员变量： private final ReentrantLock lock = new ReentrantLock(); private fin

素颜马尾好姑娘i/ 2021年12月22日 19:59/ 0 赞/ 300 阅读

相关多线程003 - 再谈CyclicBarrier

java.util.concurrent.CyclicBarrier也是JDK 1.5提供的一个同步辅助类（为什么用也呢？参见[再谈CountDownLatch][Coun

拼搏现实的明天。/ 2021年09月25日 15:56/ 0 赞/ 322 阅读