Exchanger两个线程之间交换数据
2015-08-14 10:36
826 查看
类java.util.concurrent.Exchanger 提供了一个同步点,在这个同步点,一对线程可以交换数据。每个线程通过exchange()方法的入口提供数据给他的伙伴线程,并接收他的伙伴线程提供的数据,并返回。以下附上测试DEMO。
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Exchanger;
/**
* 两个线程之间进行数据交换
* @author li
*
*/
public class ExchangerDemo {
private static final Exchanger<List<Object>> exc=new Exchanger<List<Object>>();
public static void main(String[] args) {
new Thread(new DataProducer()).start();
new Thread(new DataConsumer()).start();
}
/**
* 生成者
* @author li
*
*/
static class DataProducer implements Runnable{
private List<Object> list=new ArrayList<Object>();
@Override
public void run() {
for(int i=0;i<5;i++){
System.out.println(Thread.currentThread().getId()+":生产一个数据耗时一秒");
list.add(new Date());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
//IG
}
}
try {
System.out.println(Thread.currentThread().getId()+"交换。。。。。。start");
list =exc.exchange(list);//阻塞等待交换
System.out.println(Thread.currentThread().getId()+"交换。。。。。。end");
} catch (InterruptedException e) {
//IG
}
for(Iterator<Object> it=list.iterator();it.hasNext();){
System.out.println("Producer:"+it.next());
}
}
}
/**
* 消费者
* @author li
*
*/
static class DataConsumer implements Runnable{
private List<Object> list=new ArrayList<Object>();
@Override
public void run() {
for(int i=0;i<5;i++){
System.out.println(Thread.currentThread().getId()+":写白条");
list.add("这是一个收条");
}
try {
System.out.println(Thread.currentThread().getId()+"交换。。。。。。start");
list =exc.exchange(list);
System.out.println(Thread.currentThread().getId()+"交换。。。。。。end");
} catch (InterruptedException e) {
//IG
}
for(Iterator<Object> it=list.iterator();it.hasNext();){
Date date=(Date)it.next();
System.out.println("Consumer:"+date);
}
}
}
}运行结果:
8:生产一个数据耗时一秒
9:写白条
9:写白条
9:写白条
9:写白条
9:写白条
9交换。。。。。。start
8:生产一个数据耗时一秒
8:生产一个数据耗时一秒
8:生产一个数据耗时一秒
8:生产一个数据耗时一秒
8交换。。。。。。start
9交换。。。。。。end
8交换。。。。。。end
Producer:这是一个收条
Producer:这是一个收条
Producer:这是一个收条
Producer:这是一个收条
Producer:这是一个收条
Consumer:Fri Aug 14 10:38:42 CST 2015
Consumer:Fri Aug 14 10:38:43 CST 2015
Consumer:Fri Aug 14 10:38:44 CST 2015
Consumer:Fri Aug 14 10:38:45 CST 2015
Consumer:Fri Aug 14 10:38:46 CST 2015
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.Exchanger;
/**
* 两个线程之间进行数据交换
* @author li
*
*/
public class ExchangerDemo {
private static final Exchanger<List<Object>> exc=new Exchanger<List<Object>>();
public static void main(String[] args) {
new Thread(new DataProducer()).start();
new Thread(new DataConsumer()).start();
}
/**
* 生成者
* @author li
*
*/
static class DataProducer implements Runnable{
private List<Object> list=new ArrayList<Object>();
@Override
public void run() {
for(int i=0;i<5;i++){
System.out.println(Thread.currentThread().getId()+":生产一个数据耗时一秒");
list.add(new Date());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
//IG
}
}
try {
System.out.println(Thread.currentThread().getId()+"交换。。。。。。start");
list =exc.exchange(list);//阻塞等待交换
System.out.println(Thread.currentThread().getId()+"交换。。。。。。end");
} catch (InterruptedException e) {
//IG
}
for(Iterator<Object> it=list.iterator();it.hasNext();){
System.out.println("Producer:"+it.next());
}
}
}
/**
* 消费者
* @author li
*
*/
static class DataConsumer implements Runnable{
private List<Object> list=new ArrayList<Object>();
@Override
public void run() {
for(int i=0;i<5;i++){
System.out.println(Thread.currentThread().getId()+":写白条");
list.add("这是一个收条");
}
try {
System.out.println(Thread.currentThread().getId()+"交换。。。。。。start");
list =exc.exchange(list);
System.out.println(Thread.currentThread().getId()+"交换。。。。。。end");
} catch (InterruptedException e) {
//IG
}
for(Iterator<Object> it=list.iterator();it.hasNext();){
Date date=(Date)it.next();
System.out.println("Consumer:"+date);
}
}
}
}运行结果:
8:生产一个数据耗时一秒
9:写白条
9:写白条
9:写白条
9:写白条
9:写白条
9交换。。。。。。start
8:生产一个数据耗时一秒
8:生产一个数据耗时一秒
8:生产一个数据耗时一秒
8:生产一个数据耗时一秒
8交换。。。。。。start
9交换。。。。。。end
8交换。。。。。。end
Producer:这是一个收条
Producer:这是一个收条
Producer:这是一个收条
Producer:这是一个收条
Producer:这是一个收条
Consumer:Fri Aug 14 10:38:42 CST 2015
Consumer:Fri Aug 14 10:38:43 CST 2015
Consumer:Fri Aug 14 10:38:44 CST 2015
Consumer:Fri Aug 14 10:38:45 CST 2015
Consumer:Fri Aug 14 10:38:46 CST 2015
相关文章推荐
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- Python3写爬虫(四)多线程实现数据爬取
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序
- 二叉查找树