欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

CyclicBarrier

程序员文章站 2022-04-20 16:13:24
...

 

 

public class CyclicBarrierTest {

	 
	//在初次的4个线程越过barrier状态后,又可以用来进行新一轮的使用。而CountDownLatch无法进行重复使用。
	public static void main(String[] args) throws InterruptedException {
		 ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(10);
		int num = 5 ;
		CyclicBarrier cyclicBarrier = new CyclicBarrier(num);
		for (int i = 0; i < 5; i++) {
			newFixedThreadPool.submit(new CyclicBarrierRunnable(cyclicBarrier));
		} 
		System.out.println("==========end===1========"+System.currentTimeMillis());
        
		Thread.sleep(5000);
		
		for (int i = 0; i < 5; i++) {
			newFixedThreadPool.submit(new CyclicBarrierRunnable(cyclicBarrier));
		} 
		System.out.println("==========end===2========"+System.currentTimeMillis());
		
		newFixedThreadPool.shutdown();
	}
	
	public static class CyclicBarrierRunnable implements Runnable{

		private CyclicBarrier cyclicBarrier;
		
		public CyclicBarrierRunnable(CyclicBarrier cyclicBarrier) {
			this.cyclicBarrier = cyclicBarrier;
		}

		@Override
		public void run() { 
			try {
				cyclicBarrier.await();
				Thread.sleep(1000);
				System.out.println("====================="+System.currentTimeMillis());
                 
                 
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (BrokenBarrierException e) {
				e.printStackTrace();
			}
		}
		
	}
}

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

捐助开发者 

在兴趣的驱动下,写一个免费的东西,有欣喜,也还有汗水,希望你喜欢我的作品,同时也能支持一下。 当然,有钱捧个钱场(支持支付宝和微信 以及扣扣群),没钱捧个人场,谢谢各位。

 

个人主页http://knight-black-bob.iteye.com/


CyclicBarrier 
            
    
    博客分类: java concurrentjava CyclicBarrierjavaconcurrent CyclicBarrier 
            
    
    博客分类: java concurrentjava CyclicBarrierjavaconcurrent CyclicBarrier 
            
    
    博客分类: java concurrentjava CyclicBarrierjavaconcurrent 
 
 
 谢谢您的赞助,我会做的更好!