首页 > 编程语言 > 详细

线程的工具类(Exchange)

时间:2017-02-10 01:57:19      阅读:299      评论:0      收藏:0      [点我收藏+]
public class Exchanger<V>extends Object

可以在对中对元素进行配对和交换的线程的同步点。每个线程将条目上的某个方法呈现给 exchange 方法,与伙伴线程进行匹配,并且在返回时接收其伙伴的对象。Exchanger 可能被视为 SynchronousQueue 的双向形式。Exchanger 可能在应用程序(比如遗传算法和管道设计)中很有用。 

实例:

import java.util.concurrent.Exchanger;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
* 线程间的交换数据
*
* @author wangyi
* @version 1.0 <br />
* <a href="www.baidu.com">百度一下</a>
*/
public class ExchagerTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
Exchanger<String> exchange = new Exchanger<String>();
service.execute(new MyThread<String>("爱情", exchange, "爱情"));
service.execute(new MyThread<String>("关晓彤", exchange, "关晓彤"));
service.shutdown();

}

static class MyThread<T> extends Thread {
private T data;
private Exchanger<T> exchange;

public MyThread(T data, Exchanger<T> exchange, String name) {
this.data = data;
this.exchange = exchange;
setName(name);
}

@Override
public void run() {
System.out.println(getName() + "正准备把" + data + "交换出去");
try {
Thread.sleep((int) (Math.random() * 10000));
T datas = exchange.exchange(data);
System.out.println(getName() + "换回的为:" + datas);
} catch (Exception e) {
e.printStackTrace();
}

}
}

}

线程的工具类(Exchange)

原文:http://www.cnblogs.com/wanglaicai/p/6384698.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!