欢迎来到Doc100.Net免费学习资源知识分享平台!
您的位置:首页 > 程序异常 >

java线程系列-同步器之exchanger

更新时间: 2014-01-05 03:03:34 责任编辑: Author_N1

 

java线程系列---同步器之Exchanger

Exchanger允许两个线程在集合点交换对象,它在多流水线设计中是有用的

例子:线程间的数据交换,比如:两个人约定在某个地点交易,一手交钱,一手交货,当一个人先到指定地点,则这个人在此处等着,直到另一人到达此处才完成交易

public class ExchangerTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final Exchanger exchanger = new Exchanger();
service.execute(new Runnable(){
public void run() {
try {
String data1 = "zxx";
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() + 
"换回的数据为" + data2);
}catch(Exception e){

}
}
});
service.execute(new Runnable(){
public void run() {
try {
String data1 = "lhm";
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() + 
"换回的数据为" + data2);
}catch(Exception e){

}
}
});
}
}

上一篇:上一篇
下一篇:下一篇

 

随机推荐程序问答结果

 

 

如对文章有任何疑问请提交到问题反馈,或者您对内容不满意,请您反馈给我们DOC100.NET论坛发贴求解。
DOC100.NET资源网,机器学习分类整理更新日期::2014-01-05 03:03:34
如需转载,请注明文章出处和来源网址:http://www.doc100.net/bugs/t/17825/
本文WWW.DOC100.NET DOC100.NET版权所有。