`
raymond.chen
  • 浏览: 1450658 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

CyclicBarrier的使用

 
阅读更多

CyclicBarrier是一个同步辅助类,允许一组线程互相等待,直到到达某个公共屏障点 (common barrier point)。因为该barrier在释放等待线程后可以重用,所以称它为循环的barrier。

 

CyclicBarrier支持一个可选的Runnable命令,在一组线程中的最后一个线程到达之后(但在释放所有线程之前),该命令只在每个屏障点运行一次。

 

public class CyclicBarrierTest {
	private static CyclicBarrier barrier;
	private static int threadCount = 2; //每次同步执行的线程数
	
	public static void main(String[] args) {
		barrier = new CyclicBarrier(threadCount, ()->{
			//如果某个线程内部抛异常(中断、失败、超时),Barrier会被标识为broken,则不会执行到这里
			System.out.println("所有线程已成功处理完,此处进行统一处理!");
			
			//重置屏障,开始新一轮同步等待处理
			barrier.reset();
		});
		
		while(true){
			new Writer(barrier, 3000).start();
			try {
				TimeUnit.MILLISECONDS.sleep(1000);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	}
	
	static class Writer extends Thread{
		private CyclicBarrier barrier;
		private long timeout;
		
		public Writer(CyclicBarrier barrier, long timeout){
			this.barrier = barrier;
			this.timeout = timeout;
		}
		
		@Override
		public void run() {
			try {
				int sleep = ThreadLocalRandom.current().nextInt(2000);
				System.out.println(Thread.currentThread().getName() + ": " + sleep);
				TimeUnit.MILLISECONDS.sleep(sleep);
				
				//await:告诉CyclicBarrier本线程已经到达同步点,然后当前线程被阻塞
				barrier.await(timeout, TimeUnit.MILLISECONDS);
				
			} catch (InterruptedException|TimeoutException|BrokenBarrierException ex) {
				System.out.println(Thread.currentThread().getName() + ":" + ex.toString());
			}

			if(barrier.isBroken()){
				System.out.println("CyclicBarrier已Broken");
			}else{
				System.out.println(Thread.currentThread().getName() + ": 所有线程已成功处理完,本线程继续往下执行");
			}
		}
	}
	
}

 

分享到:
评论

相关推荐

    CyclicBarrier的用法

    `ThreadDemo`可能是一个简单的示例程序,它演示了如何使用`CyclicBarrier`来控制多个线程的同步行为。通常,这样的示例会创建多个线程,每个线程执行一些任务,然后在`CyclicBarrier`上等待,直到所有线程都完成任务...

    java.CyclicBarrier(处理方案示例).md

    下面是一个简单的CyclicBarrier使用示例。假定有五个线程需要协作完成一个任务,在五个线程都到达某个执行点后,才允许它们继续执行后续的操作。示例中的CyclicBarrier设置为需要五个线程到达屏障点。每个线程在完成...

    CyclicBarrier的使用以及注意事项

    CyclicBarrier的使用以及注意事项

    java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf

    java并发编程中CountDownLatch和CyclicBarrier的使用借鉴 java并发编程中CountDownLatch和CyclicBarrier是两个非常重要的线程控制和调度工具,经常被用于解决多线程程序设计中的线程等待问题。本文将对...

    CountDownLatch和CyclicBarrier用法实例大全

    - 使用CyclicBarrier实现多线程分治策略,每个子任务完成后来一次全局计算的例子。 - 线程间的异常处理,包括中断和超时的处理。 - 结合Future和ExecutorService,进一步提高并发性能和灵活性。 - 在大型项目中的...

    Java并发实例之CyclicBarrier的使用

    Java并发实例之CyclicBarrier的使用 CyclicBarrier是Java中的一种多线程并发控制实用工具,和CountDownLatch非常类似,它也可以实现线程间的计数等待,但是它的功能比CountDownLatch更加复杂且强大。CyclicBarrier...

    java并发编程中CountDownLatch和CyclicBarrier的使用.pdf

    在游戏场景中,如果四个玩家需要同时开始游戏,就可以使用CyclicBarrier。`CyclicBarrier(int parties, Runnable barrierAction)`构造函数接受两个参数,`parties`表示需要等待的线程数,`barrierAction`是所有线程...

    java多线程之CyclicBarrier的使用方法

    Java多线程之CyclicBarrier的使用方法 Java多线程之CyclicBarrier的使用方法是Java多线程编程中的一种同步机制,用于实现多个线程之间的同步协作。CyclicBarrier是Java 5中引入的一种同步机制,用于让多个线程等待...

    java.CyclicBarrier.md

    使用CyclicBarrier时,可以指定一个栅栏动作,当所有线程都达到屏障点后,会执行这个动作。这可以是一个在执行其他同步点操作之前需要执行的任务。 然而,CyclicBarrier有其局限性。它不支持重置屏障,如果需要重用...

    CyclicBarrier用法.docx

    1. **重复使用性**:与CountDownLatch不同,CyclicBarrier可以在所有线程都达到屏障点后重置,允许再次使用。这意味着一旦所有线程都完成各自的任务并调用await()方法,屏障将被重置,计数器恢复到初始值,可以进行...

    java.CyclicBarrier(解决方案).md

    CyclicBarrier的主要特点在于它是循环使用的,也就是说,一旦所有等待的线程都被释放,该CyclicBarrier就可以被重用,适用于需要多次在多个线程间同步的场景。 CyclicBarrier的典型应用场景包括:多线程同时开始...

    CyclicBarrier(处理方案示例).md

    CyclicBarrier是一种在Java并发编程中广泛使用的同步工具,它允许多个线程在执行到某个共同的同步点时彼此等待。当所有线程都达到这个同步点后,它们将被释放并继续执行后续任务。这种机制非常适合需要多个线程协作...

    Java中的CyclicBarrier类最全讲义

    - **可重用性**:`CyclicBarrier`是可循环使用的,而`CountDownLatch`一旦计数到零就不能再使用。 - **屏障点动作**:`CyclicBarrier`允许指定当所有线程到达屏障点时执行的动作,而`CountDownLatch`没有这个功能。 ...

    Java中的CountDownLatch与CyclicBarrier:深入理解与应用实践

    本文将详细介绍CountDownLatch和CyclicBarrier的工作原理、使用场景以及如何在实际项目中应用它们。 CountDownLatch和CyclicBarrier是Java并发编程中两个非常有用的同步工具,它们在不同的场景下有着各自的优势。...

    Java并发系列之CyclicBarrier源码分析

    Java并发系列之CyclicBarrier源码分析 CyclicBarrier是Java并发系列中的一种同步工具类,用于实现一组线程相互等待。当所有线程都到达某个屏障点后,再进行后续的操作。下面是对CyclicBarrier源码的详细分析。 ...

    CyclicBarrier,reentrantlock,condition模拟抢票

    用CyclicBarrier,reentrantlock,condition来完成同时购买,同步购买的功能 JUC系列之模拟抢票(N人同时抢票,票不足系统补仓,N-M人继续抢票) http://blog.csdn.net/crazyzxljing0621/article/details/77891620

    Java中CyclicBarrier的用法分析

    `CyclicBarrier`的名字来源于它的可重用性,一旦一组线程通过了屏障,它可以重置并再次使用,而不是像`CountDownLatch`那样只能使用一次。 在上述的测试代码中,我们创建了一个`CyclicBarrier`实例,设置了线程数为...

    JAVA CyclicBarrier类详解.docx

    下面是一个使用CyclicBarrier的典型例子,展示了一个并行分解问题的解决过程: ```java class Solver { final int N; final float[][] data; final CyclicBarrier barrier; class Worker implements Runnable...

    java线程并发cyclicbarrier类使用示例

    Java中的`CyclicBarrier`是用于多线程同步的一个强大工具,主要应用于一组线程需要在继续执行之前等待其他线程到达某个特定点的情况。它允许开发者定义一个屏障点,只有当所有参与的线程都到达这个屏障点时,它们才...

Global site tag (gtag.js) - Google Analytics