`
海浪儿
  • 浏览: 275933 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

闭锁/栅栏/信号量/FutureTask分析及使用

阅读更多

闭锁/栅栏/信号量/FutureTask分析及使用

 

1、闭锁

 

用途:可用于命令一组线程在同一个时刻开始执行某个任务,或者等待一组相关的操作结束。尤其适合计算并发执行某个任务的耗时。

 

public class CountDownLatchTest {

	public void timeTasks(int nThreads, final Runnable task) throws InterruptedException{
		final CountDownLatch startGate = new CountDownLatch(1);
		final CountDownLatch endGate = new CountDownLatch(nThreads);
		
		for(int i = 0; i < nThreads; i++){
			Thread t = new Thread(){
				public void run(){
					try{
						startGate.await();
						try{
							task.run();
						}finally{
							endGate.countDown();
						}
					}catch(InterruptedException ignored){
						
					}
					
				}
			};
			t.start();
		}
		
		long start = System.nanoTime();
		System.out.println("打开闭锁");
		startGate.countDown();
		endGate.await();
		long end = System.nanoTime();
		System.out.println("闭锁退出,共耗时" + (end-start));
	}
	
	public static void main(String[] args) throws InterruptedException{
		CountDownLatchTest test = new CountDownLatchTest();
		test.timeTasks(5, test.new RunnableTask());
	}
	
	class RunnableTask implements Runnable{

		@Override
		public void run() {
			System.out.println("当前线程为:" + Thread.currentThread().getName());
			
		}	
	}

 

执行结果为:
打开闭锁
当前线程为:Thread-0
当前线程为:Thread-3
当前线程为:Thread-2
当前线程为:Thread-4
当前线程为:Thread-1
闭锁退出,共耗时1109195

 2、栅栏

 

用途:用于阻塞一组线程直到某个事件发生。所有线程必须同时到达栅栏位置才能继续执行下一步操作,且能够被重置以达到重复利用。而闭锁式一次性对象,一旦进入终止状态,就不能被重置

 

public class CyclicBarrierTest {
	private final CyclicBarrier barrier;
	private final Worker[] workers;

	public CyclicBarrierTest(){
		int count = Runtime.getRuntime().availableProcessors();
		this.barrier = new CyclicBarrier(count,
				new Runnable(){

					@Override
					public void run() {
						System.out.println("所有线程均到达栅栏位置,开始下一轮计算");
					}
			
		});
		this.workers = new Worker[count];
		for(int i = 0; i< count;i++){
			workers[i] = new Worker(i);
		}
	}
	private class Worker implements Runnable{
		int i;
		
		public Worker(int i){
			this.i = i;
		}

		@Override
		public void run() {
			for(int index = 1; index < 3;index++){
				System.out.println("线程" + i + "第" + index + "次到达栅栏位置,等待其他线程到达");
				try {
					//注意是await,而不是wait
					barrier.await();
				} catch (InterruptedException e) {
					e.printStackTrace();
					return;
				} catch (BrokenBarrierException e) {
					e.printStackTrace();
					return;
				}
			}
		}
		
	}
	
	public void start(){
		for(int i=0;i<workers.length;i++){
			new Thread(workers[i]).start();
		}
	}
	
	public static void main(String[] args){
		new CyclicBarrierTest().start();
	}
}

 

执行结果为:
线程0第1次到达栅栏位置,等待其他线程到达
线程1第1次到达栅栏位置,等待其他线程到达
线程2第1次到达栅栏位置,等待其他线程到达
线程3第1次到达栅栏位置,等待其他线程到达
所有线程均到达栅栏位置,开始下一轮计算
线程3第2次到达栅栏位置,等待其他线程到达
线程2第2次到达栅栏位置,等待其他线程到达
线程0第2次到达栅栏位置,等待其他线程到达
线程1第2次到达栅栏位置,等待其他线程到达
所有线程均到达栅栏位置,开始下一轮计算

 3、信号量

 

用途:用来控制同时访问某个特定资源的操作数量,或者同时执行某个指定操作的数量。计数信号量可以用来实现某种资源池,或者对容器施加边界。

 

public class SemaphoreTest<T> {
	private final Set<T> set;
	
	private final Semaphore sema;
	
	public SemaphoreTest(int bound){
		this.set = Collections.synchronizedSet(new HashSet<T>());
		this.sema = new Semaphore(bound);
	}
	
	public boolean add(T o) throws InterruptedException{
		sema.acquire();
		boolean wasAdded = false;
		try{
			wasAdded = set.add(o);
			return wasAdded;
		}finally{
			if(!wasAdded){
				sema.release();
			}
		}
	}
	
	public boolean remove(T o){
		boolean wasRemoved = set.remove(o);
		if(wasRemoved){
			sema.release();
		}
		return wasRemoved;
	}
	
	public static void main(String[] args) throws InterruptedException{
		int permits = 5;
		int elements = permits + 1;
		SemaphoreTest<Integer> test = new SemaphoreTest<Integer>(permits);
		for(int i = 0;i < elements; i++){
			test.add(i);
		}
	}
}

 输出结果:由于实际待添加的元素个数大于信号量所允许的数量,因此最后一次添加时,会一直阻塞。

 

4、巧用FutureTask缓存计算过程

当一个计算的代价比较高,譬如比较耗时,或者耗资源,为了避免重复计算带来的浪费,当第一次计算后,通常会将结果缓存起来。比较常见的方式就是使用synchronized进行同步,但该方式带来的代价是被同步的代码只能被串行执行,如果有多个线程在排队对待计算结果,那么针对最后一个线程的计算时间可能比没有使用缓存的时间会更长。

第二种方式是采用ConcurrentHashMap,但对于耗时比较长的计算过程来说,该方式也存在一个漏洞。如果在第一个线程正在计算的过程中,第二个线程开始获取结果,会发现缓存里没有缓存结果,因此第二个线程又启动了同样的计算,这样就导致重复计算,违背了缓存的初衷。计算过程越长,则出现这种重复计算的几率就会越大。

 

通过第二种方式的缺点分析,得知真正要缓存的应该是计算是否已被启动,而不是等待漫长的计算过程结束后,再缓存结果。一旦从缓存中得知某个计算过程已被其他线程启动,则当前线程不需要再重新启动计算,只需要阻塞等待计算结果的返回。FutureTask就是实现该功能的最佳选择。

 

public class Memoizer<A, V> implements Computable<A, V> {
	private ConcurrentMap<A, Future<V>> cache = new ConcurrentHashMap<A, Future<V>>();
	private final Computable<A, V> c;

	public Memoizer(Computable<A, V> c) {
		this.c = c;
	}

	@Override
	public V compute(final A a) {
		while (true) {
			Future<V> f = cache.get(a);
			if (null == f) {
				Callable<V> eval = new Callable<V>() {

					@Override
					public V call() throws Exception {
						return c.compute(a);
					}

				};
				FutureTask<V> ft = new FutureTask<V>(eval);
				f = cache.putIfAbsent(a, ft);
				if (null == f) {
					f = ft;
					ft.run();
				}
			}
			try {
				return f.get();
			} catch (InterruptedException e) {
				e.printStackTrace();
				cache.remove(a, f);
			} catch (ExecutionException e) {
				e.printStackTrace();
			}
		}
	}

	public static void main(String[] args) throws InterruptedException,
			ExecutionException {
		Computable<Integer, String> c = new Computable<Integer, String>() {

			@Override
			public String compute(Integer a) {
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				String result = "由线程:" + Thread.currentThread().getName()
						+ "计算得到" + a + "的结果";
				return result;
			}
		};

		Memoizer<Integer, String> memoizer = new Memoizer<Integer, String>(c);

		ExecutorService executorService = Executors.newFixedThreadPool(3);

		for (int i = 0; i < 3; i++) {
			Task<Integer, String> task = new Task<Integer, String>(memoizer, 10);
			String result = executorService.submit(task).get();
			System.out.println(result);
		}
		executorService.shutdown();
	}
}
结果如下:
由线程:pool-1-thread-1计算得到10的结果
由线程:pool-1-thread-1计算得到10的结果
由线程:pool-1-thread-1计算得到10的结果
当然如果仅仅只是采用FutureTask,仅仅只是减小了启动同一个计算过程的概率。当两个线程同时经过compute方法时,还是会出现重复启动同一个计算的情况,上面的例子通过结合ConcurrentHashMap 的putIfAbsent方法解决了这个问题

 

分享到:
评论

相关推荐

    JAVA并发编程实践-构建执行程序块-学习笔记

    例如,使用latch闭锁、FutureTask、Semaphore计数信号量等来实现线程安全。 latch闭锁是指在多线程环境下,使用闭锁来实现线程安全。例如,在桌⾯搜索时,使用闭锁来实现线程安全,以避免出现死锁、竞态条件等问题...

    Java并发编程(学习笔记).xmind

    (3)使用信号量将任何一种容器变成有界阻塞容器 栅栏 能够阻塞一组线程直到某个事件发生 栅栏和闭锁的区别 所有线程必须同时到达栅栏位置,才能继续执行 闭锁用于等待事件,而栅栏...

    Java 并发编程实战

    5.5.3 信号量 5.5.4 栅栏 5.6 构建高效且可伸缩的结果缓存 第二部分 结构化并发应用程序 第6章 任务执行 6.1 在线程中执行任务 6.1.1 串行地执行任务 6.1.2 显式地为任务创建线程 6.1.3 无限制创建线程的...

    三菱FX系列PLC与昆仑通态触摸屏在磨床控制中的应用及优化

    内容概要:本文详细介绍了使用三菱FX系列PLC与昆仑通态/三菱GT系列触摸屏进行磨床控制的具体方法和技术细节。主要内容涵盖PLC的梯形图编程,包括脉冲输出控制、急停逻辑、伺服电机控制等;触摸屏的HMI界面设计,涉及砂轮磨损补偿、数值输入框的边界检查、动态效果实现等;以及PLC与触摸屏之间的通讯配置和调试技巧。文中还分享了许多实际操作中的经验和注意事项,如脉冲输出模式的设置、通讯参数的一致性、硬件连接的可靠性等。 适合人群:从事工业自动化控制领域的工程师和技术人员,尤其是对PLC编程和HMI设计有一定基础的人群。 使用场景及目标:适用于中小型加工车间的磨床控制系统的设计与调试。主要目标是提高磨床控制系统的稳定性和精度,减少调试时间和错误发生的可能性。 其他说明:文章不仅提供了具体的编程代码和配置步骤,还分享了许多实际操作中的经验和教训,帮助读者更好地理解和掌握相关技术和技巧。

    邢台市-沙河市--街道行政区划_130582_Shp-wgs84坐标系.rar

    街道级行政区划shp数据,wgs84坐标系,直接下载使用。

    邢台市-内丘县--街道行政区划_130523_Shp-wgs84坐标系.rar

    街道级行政区划shp数据,wgs84坐标系,直接下载使用。

    IEEE Standard for Verilog Hardware Description Language.pdf.wim

    IEEE Standard for Verilog Hardware Description Language.pdf.wim

    晋中市-和顺县-街道行政区划_140723_Shp数据-wgs84坐标系.rar

    晋中市-和顺县-街道行政区划_140723_Shp数据-wgs84坐标系.rar

    FPGA与CY7C68013A实现USB2.0多通道高精度数据采集系统的详细解析

    内容概要:本文深入探讨了基于FPGA(Xilinx Spartan-6)和CY7C68013A的多通道数据采集系统的设计与实现。系统能够支持八路或十六路24位ADC的同时采样,并通过USB2.0接口将数据稳定传输至上位机。文中详细介绍了硬件架构的选择、FPGA内部FIFO设计、USB固件配置以及上位机软件开发等多个方面的关键技术点。特别强调了跨时钟域FIFO设计、端点配置优化、多线程同步读取等技巧对于提高系统性能的重要作用。此外,还分享了许多实际开发过程中遇到的问题及其解决方案,如电磁兼容性处理、时钟漂移补偿、数据包丢失预防等。 适合人群:从事嵌入式系统开发、FPGA编程、USB通信协议研究的专业技术人员,尤其是那些正在探索高效数据采集方案的研发人员。 使用场景及目标:适用于需要进行多通道同步数据采集的应用场合,比如工业自动化检测设备、医疗仪器、环境监测等领域。目标是帮助开发者掌握构建高性能、可靠性的数据采集系统的完整流程和技术要点。 其他说明:作者不仅提供了详细的代码片段作为参考,还分享了很多宝贵的实践经验,有助于读者更好地理解和应用相关技术。

    电力现货价格建模中基于贝叶斯校正与跳变分量的MCMC算法Matlab/C++实现及其应用

    内容概要:本文探讨了利用贝叶斯校正和跳变分量在电力现货价格建模中的应用,特别是通过MCMC算法进行参数估计的方法。文中详细介绍了模型的基本架构,即均值回归过程与多组跳变过程的叠加,并展示了如何通过Matlab和C++-Mex实现这一复杂的模型。模型的核心在于通过数据驱动的方式确定最优跳变分量个数,从而更好地捕捉电力市场价格的尖峰特性。此外,还讨论了模型的实际应用效果以及不同市场之间的差异,强调了贝叶斯框架在极端事件预测方面的优势。 适合人群:从事电力市场研究、金融工程、数据分析的专业人士,尤其是对贝叶斯统计和MCMC算法有一定了解的研究人员和技术开发者。 使用场景及目标:适用于希望提高电力现货价格预测准确性的人群,尤其是在面对频繁波动的市场环境时。通过引入多个带符号的跳变分量,能够更精确地捕捉市场动态,帮助决策者制定更好的风险管理策略。 其他说明:文中提供了详细的代码实现和后验诊断方法,确保模型不仅理论上可行,而且在实践中也能高效运行。特别指出,在不同市场环境下,模型参数会有不同的表现形式,体现了模型的高度灵活性和适应性。

    上市公司环境排放明细(2008-2021年)

    上市公司环境排放明细(2008-2021年)

    信捷XC3 PLC与施耐德ATV12变频器自动化通讯方案及应用

    内容概要:本文详细介绍了信捷XC3 PLC与施耐德ATV12变频器之间的自动化通讯解决方案。主要内容涵盖硬件连接、PLC程序逻辑设计、触摸屏交互以及断电自恢复等功能。首先,硬件方面采用RS485接口进行连接,确保通信稳定。其次,PLC程序分为三个主要部分:上电自检、实时状态轮询和频率设定。通过Modbus协议实现设备间的数据交互,并解决了通讯冲突等问题。此外,触摸屏提供了友好的人机界面,支持频率设定和状态监控。最后,实现了断电自恢复功能,确保设备在意外断电后能够自动恢复正常运行。 适合人群:从事工业自动化领域的工程师和技术人员,特别是熟悉PLC编程和变频器应用的专业人士。 使用场景及目标:适用于需要提高生产设备自动化水平的企业,旨在减少人工干预,提升生产效率和设备可靠性。具体应用场景包括但不限于工厂生产线、自动化控制系统等。 其他说明:文中提供了详细的代码示例和调试技巧,帮助读者更好地理解和实施该方案。同时强调了硬件配置和参数设置的重要性,为实际项目提供宝贵的实践经验。

    120吨双级反渗透与混床系统的S7-200 Smart PLC自动化控制及加药程序详解

    内容概要:本文详细介绍了120吨双级反渗透与混床系统的自动化控制系统及其加药程序。系统采用西门子S7-200 Smart PLC进行控制,涵盖了一键制水、阻垢剂和杀菌剂的自动投加、反渗透膜保护、混床再生控制等功能。文中展示了具体的PLC编程逻辑,如定时器的应用、硬件互锁设计、模拟量处理以及HMI画面设计等。此外,还包括详细的电气图纸和操作维护手册,提供了丰富的实战经验和优化建议。 适合人群:具备一定PLC编程基础的自动化工程师和技术人员。 使用场景及目标:适用于工业水处理领域的自动化控制系统设计与实施,帮助工程师理解和掌握S7-200 Smart PLC的实际应用技巧,提高系统的可靠性和效率。 其他说明:文章不仅提供了完整的程序代码和注释,还分享了许多实战中的踩坑记录和优化建议,对于初学者来说是非常宝贵的学习资源。

    包头市-达尔罕茂明安联合旗-街道行政区划_150223_Shp数据-wgs84坐标系.rar

    包头市-达尔罕茂明安联合旗-街道行政区划_150223_Shp数据-wgs84坐标系.rar

    HCIA-Datacom高阶:vlan、vlanif、单臂路由、静态路由、ospf综合实验

    HCIA-Datacom高阶:vlan、vlanif、单臂路由、静态路由、ospf综合实验

    张家口市-桥东区--街道行政区划_130702_Shp-wgs84坐标系.rar

    街道级行政区划shp数据,wgs84坐标系,直接下载使用。

    LabVIEW测试系统在工业自动化领域的应用与优势解析

    内容概要:本文详细介绍了LabVIEW测试系统在工业自动化领域的应用及其优势。首先,通过具体案例展示了LabVIEW在24小时不间断测试PCBA模块中的高效性和稳定性,特别是在异常处理和数据存储方面的强大功能。其次,文章强调了LabVIEW在硬件交互、PID控制、版本管理和文档生成等方面的优势,如利用DAQmx驱动进行精确的压力控制,以及通过Project Library机制实现无缝版本升级。此外,文中还提到LabVIEW的图形化编程特性使得复杂工程需求能够快速落地,并且提供了丰富的信号处理函数库,适用于各种测试场景。最后,文章讨论了LabVIEW在商用系统中的部署能力和售后服务支持,如快速生成报表和稳定的远程监控功能。 适合人群:从事工业自动化、测试系统开发的工程师和技术人员。 使用场景及目标:① 实现高效的工业自动化测试系统;② 提高测试系统的稳定性和可靠性;③ 加速复杂工程需求的快速落地;④ 提供便捷的版本管理和文档生成工具。 其他说明:尽管LabVIEW的图形化编程对习惯文本编码的工程师有一定学习曲线,但对于大多数标准测试场景而言,其提供的稳定性和易用性使其成为理想的开发工具。

    光伏充电站动态能量调度策略:基于MATLAB的电动汽车充放电优化与光伏利用率提升

    内容概要:本文详细介绍了光伏充电站的能量调度策略及其MATLAB实现。主要内容包括:定义关键变量如光伏出力波动容忍阈值、电价系数等,建立准入控制机制将充电站分为‘饥饿’和‘饱和’两种模式,通过计算每辆车的充放电灵活度进行车辆调度,采用动态定价策略激励车主错峰充电,以及运用凸优化算法求解最优充电方案。最终实现了光伏利用率的显著提高和车主充电体验的优化。 适合人群:对新能源汽车充电站运营、光伏能源管理和智能调度算法感兴趣的工程师和技术人员。 使用场景及目标:适用于希望深入了解并应用光伏充电站能量调度策略的研究人员和从业者。主要目标是在确保车主按时充电的前提下,最大限度地利用光伏发电,减少能源浪费,同时通过动态定价机制平衡供需关系。 其他说明:文中提供了详细的代码片段和图表解释,帮助读者更好地理解和复现该调度策略。此外,还讨论了一些实际应用中的挑战和改进建议,如精确定位车辆停留时间和引入联邦学习更新灵活度模型等。

    基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip

    基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip,个人经导师指导并认可通过的高分设计项目,评审分99分,代码完整确保可以运行,小白也可以亲自搞定,主要针对计算机相关专业的正在做大作业的学生和需要项目实战练习的学习者,可作为毕业设计、课程设计、期末大作业。 基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue3实现的仿小米商城项目源代码+项目详细文档.zip基于Vue

    基于PMU的配电系统非线性状态估计MATLAB实现及应用

    内容概要:本文详细介绍了基于PMU(phasor measurement unit)的配电系统状态估计(SSE)中引入非线性模型的方法及其实际应用。传统的线性模型将接地电阻视为固定参数,无法适应实际环境中接地电阻的变化,导致估计精度下降。文中提出了一种改进的非线性状态估计方法,将接地电阻作为状态变量纳入模型,通过构建非线性观测方程和实时更新雅可比矩阵,利用牛顿-拉夫森法进行求解。这种方法显著提高了中性点电压(NEV)和其他关键参数的估计精度,在复杂环境如雷雨天气下的表现尤为突出。此外,文章还讨论了大规模系统测试中的优化技术和实际应用案例,展示了该方法的成功预警实例。 适合人群:电力系统研究人员、电气工程师、从事配电系统状态估计的研究者和技术开发者。 使用场景及目标:适用于需要精确估计配电系统状态的应用场合,尤其是在接地电阻波动较大或存在多接地节点的情况下。主要目标是提高状态估计的准确性,确保电力系统的稳定性和安全性。 其他说明:文中提供了详细的MATLAB代码实现,并附有测试案例和性能对比数据。代码已在GitHub上开源,支持进一步的研究和开发。

Global site tag (gtag.js) - Google Analytics