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

Java编程线程同步工具Exchanger的使用实例解析

程序员文章站 2022-07-12 08:04:03
本文研究的主要是java编程线程同步工具exchanger的使用,下面看看具体内容。   如果两个线程在运行过程中需要交换彼此的信息,比如一个数据或者使用的空间,就需要用...

本文研究的主要是java编程线程同步工具exchanger的使用,下面看看具体内容。

  如果两个线程在运行过程中需要交换彼此的信息,比如一个数据或者使用的空间,就需要用到exchanger这个类,exchanger为线程交换信息提供了非常方便的途径,它可以作为两个线程交换对象的同步点,只有当每个线程都在进入 exchange ()方法并给出对象时,才能接受其他线程返回时给出的对象。

  每次只能两个线程交换数据,如果有多个线程,也只有两个能交换数据。下面看个通俗的例子:一手交钱一首交货!

public class exchangertest {
	public static void main(string[] args) {
		executorservice service = executors.newcachedthreadpool();
		final exchanger exchanger = new exchanger();
		//定义一个交换对象,用来交换数据
		//开启一个线程执行任务
		service.execute(new runnable(){
			@override
			      public void run() {
				try {
					string data1 = "海洛因";
					system.out.println("线程" + thread.currentthread().getname() 
					              + "正在把毒品" + data1 + "拿出来");
					thread.sleep((long)(math.random()*10000));
					//把要交换的数据传到exchange方法中,然后被阻塞,等待另一个线程与之交换。返回交换后的数据
					string data2 = (string)exchanger.exchange(data1);
					system.out.println("线程" + thread.currentthread().getname() + 
					          "用海洛因换来了" + data2);
				}
				catch(exception e){
				}
				finally {
					service.shutdown();
					system.out.println("交易完毕,拿着钱快跑!");
				}
			}
		}
		);
		//开启另一个线程执行任务
		service.execute(new runnable(){
			@override
			      public void run() {
				try {
					string data1 = "300万";
					system.out.println("线程" + thread.currentthread().getname() + 
					          "正在把" + data1 +"拿出来");
					thread.sleep((long)(math.random()*10000));
					string data2 = (string)exchanger.exchange(data1);
					system.out.println("线程" + thread.currentthread().getname() + 
					          "用300万弄到了" + data2);
				}
				catch(exception e){
				}
				finally {
					service.shutdown();
					system.out.println("交易完毕,拿着海洛因快跑!");
				}
			}
		}
		);
	}
}

从代码中我仿佛看到了两个人在交易毒品的场面……来看一下交易结果如何:

线程pool-1-thread-1正在把毒品海洛因拿出来
线程pool-1-thread-2正在把300万拿出来
线程pool-1-thread-2用300万弄到了海洛因
线程pool-1-thread-1用海洛因换来了300万
交易完毕,拿着海洛因快跑!
交易完毕,拿着钱快跑!

 跑的倒是快,从运行结果来看,确实实现了数据的交换,这个只是交换一个基本类型的数据而已,它真正的用处不仅仅局限于此,比如我们可以交换一个对象,这就有用了,jdk官方提到了一个高级的应用:

使用 exchanger 在线程间交换缓冲区,因此,在需要时,填充缓冲区的线程获取一个新腾空的缓冲区,并将填满的缓冲区传递给腾空缓冲区的线程。

  这就得根据实际情况了,思想和上面的一样,实际中肯定要定义一个缓冲区的类,然后两个线程之间交换的就是这个缓冲区的类即可,至于类中如何实现,就得看实际情况了。exchanger的使用就总结这么多吧~

总结

以上就是本文关于java编程线程同步工具exchanger的使用实例解析的全部内容,希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题,如有不足之处,欢迎留言指出。感谢朋友们对本站的支持!