首页 > 代码库 > Java并发编程--6.Exchanger线程间交换数据
Java并发编程--6.Exchanger线程间交换数据
在两个线程之间定义同步点,当两个线程都到达同步点时，他们交换数据结构，因此第一个线程的数据结构进入到第二个线程中，第二个线程的数据结构进入到第一个线程中
在生产者-消费者情境模式中它包含了一个数缓冲区，一个或者多个生产者，一个或者多个消费中
下面是生产者和消费者的示例:
/** * 生产者和消费者交换数据 */public class MyExchanger { public static void main(String[] args) { Exchanger<List<String>> exchanger = new Exchanger<List<String>>(); Producer1 producer = new Producer1(new ArrayList<String>(), exchanger); Consumer1 consumer = new Consumer1(new ArrayList<String>(), exchanger); new Thread(producer).start(); new Thread(consumer).start(); }}/** 生产者线程*/ class Producer1 implements Runnable{ /** * 存储交换的数据 */ private List<String> buffer; /** * 和消费者要交换的对象 */ private final Exchanger<List<String>> exchanger; Producer1(List<String> buffer,Exchanger<List<String>> exchanger){ this.buffer = buffer; this.exchanger = exchanger; } @Override public void run() { for(int i = 0 ; i < 2 ; i++){ String message = "" + i ; System.out.println("Produce的数据 : " + message); buffer.add(message); //调用exchange()与消费者进行数据交换 try { buffer = exchanger.exchange(buffer); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println("Produce收到来自Consumer的数据的长度 : " + buffer.size()); }} /** 消费者线程*/ class Consumer1 implements Runnable{ private List<String> buffer; private final Exchanger<List<String>> exchanger; public Consumer1(List<String> buffer,Exchanger<List<String>> exchanger){ this.buffer = buffer; this.exchanger = exchanger; } @Override public void run() { for(int i = 0 ; i < 2 ; i++){ //调用exchange()与消费者进行数据交换 try { buffer = exchanger.exchange(buffer); } catch (InterruptedException e) { e.printStackTrace(); } for(int j = 0 ; j < buffer.size() ; j++){ System.out.println("Consumer收到来自Produce的数据 : " + buffer.get(0)); buffer.remove(0); } } System.out.println("Consumer清空数据"); } }
控制台输出:
Produce的数据 : 0Consumer收到来自Produce的数据 : 0Produce的数据 : 1Produce收到来自Consumer的数据的长度 : 0Consumer收到来自Produce的数据 : 1Consumer清空数据
在Exchanger中，如果一个线程已经到达了exchanger节点时，对于它的伙伴节点的情况有三种：
1、如果它的伙伴节点在该线程到达之间已经调用了exchanger方法，则它会唤醒它的伙伴然后进行数据交换，得到各自数据返回。
2、如果它的伙伴节点还没有到达交换点，则该线程将会被挂起，等待它的伙伴节点到达被唤醒，完成数据交换。
3、如果当前线程被中断了则抛出异常，或者等待超时了，则抛出超时异常
Java并发编程--6.Exchanger线程间交换数据
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。