Exchanger讲解

不念不忘少年蓝@ 2022-02-14 08:11 224阅读 0赞

同步辅助工具类中的Exchanger的作用是在成对的线程之间相互传递消息，通过exchange()方法进行交换数据。例如如下示例：

>     public class TestExchanger {
>     
>         public static void main(String[] args) throws InterruptedException {
>             Exchanger<People> exchanger=new Exchanger<>();
>             Thread t1=new Thread(new TestExchangerThread(new People("小明",10),exchanger,0),"小明线程 ");
>             Thread t2=new Thread(new TestExchangerThread(new People("小红",20),exchanger,10),"小红线程 ");
>     
>             t1.start();
>             t2.start();
>             t1.join();
>             t2.join();
>             System.out.println("主线程完毕");
>         }
>     }
>     
>     class TestExchangerThread implements Runnable{
>     
>         private Exchanger<People> exchanger;
>     
>         private int seconds;
>     
>         private People people;
>     
>         public TestExchangerThread(People people,Exchanger<People> exchanger,int seconds) {
>             this.people = people;
>             this.exchanger=exchanger;
>             this.seconds=seconds;
>         }
>     
>         @Override
>         public void run() {
>             System.out.println(Thread.currentThread().getName()+"得到交换之前的值为"+people);
>             try {
>                 if(seconds>0){
>                     TimeUnit.SECONDS.sleep(seconds);
>                 }
>                 People exchange = exchanger.exchange(people);
>                 System.out.println(Thread.currentThread().getName()+"得到交换之后的值为"+exchange);
>             } catch (InterruptedException e) {
>                 e.printStackTrace();
>             }
>         }
>     }

这个例子中的exchanger.exchange()方法是一个同步点，如果其他的线程没有到达这个同步点就会阻塞当前线程。

发表评论取消回复

表情：

评论列表（有 0 条评论，224人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ交换机（Exchanges）

目录一、概念二、临时队列三、绑定四、Fanout（扇出交换机）（一）介绍（二）实战五、Direct（直接交换机）（一）介绍（二）实战六

客官°小女子只卖身不卖艺/ 2023年10月11日 20:53/ 0 赞/ 47 阅读

相关 RabbitMQ之Exchange

rabbitMQ消息模型的核心思想是生产者不会将消息直接发送给队列。生产者通常不知道消息将会被哪些消费者接收，按照刚开始里介绍的rabbitMQ中所画的，生产者不是直接将消息发

骑猪看日落/ 2022年08月24日 06:10/ 0 赞/ 183 阅读

相关 ubuntu exchange mail

原文：[http://blog.csdn.net/ailinty/article/details/6640861][http_blog.csdn.net_ailinty_art

红太狼/ 2022年02月19日 01:31/ 0 赞/ 186 阅读

相关 Exchanger讲解

同步辅助工具类中的Exchanger的作用是在成对的线程之间相互传递消息，通过exchange()方法进行交换数据。例如如下示例： > public clas

不念不忘少年蓝@/ 2022年02月14日 08:11/ 0 赞/ 225 阅读

相关 RabbitMQ Exchange 类型

Exchange 有四种类型 1、direct 点对点模型，一个消息只能被一个客户端消费。消息中的路由键routing key和Binding中的key一致，交换器就将消息

小鱼儿/ 2022年01月22日 23:29/ 0 赞/ 226 阅读

相关 Exchange 2013 安装

今天尝试安装了一下Exchange 2013.发现安装过程基本上和以前没有多大变化。软硬件要求以及安装准备都和Exchange 2010 差不多。硬件要求： CPU:

落日映苍穹つ/ 2022年01月11日 01:55/ 0 赞/ 193 阅读

相关 exchange 2007 安装

1， Command 模式下打入“winver" 可以检测当前windows系统的版本。exchange 2003级以上版本都要求装在win2003 sp3和win 2003以

墨蓝/ 2021年12月17日 14:27/ 0 赞/ 195 阅读

相关 exchange 发送邮件

package com.example.demo.test; import java.net.URI; import java.ne

朱雀/ 2021年11月17日 00:34/ 0 赞/ 411 阅读

相关 Java并发——Exchanger

Exchanger Exchanger的功能可以使2个线程之间传输数据,它比生产者/消费者模式使用的 wait/notify要更加方便。 exchange()阻塞的特性

ゝ一世哀愁。/ 2021年08月30日 22:17/ 0 赞/ 410 阅读

相关 Java Exchange 实战

一点睛当两个线程都运行都 exchanger.exchange(s)，位置，然后开始交换变量，最后继续往下执行。如果只有一个线程到达 exchanger.exch

墨蓝/ 2021年07月25日 02:37/ 0 赞/ 383 阅读