java并发数据包Exchanger线程间的数据交换器

 更新时间:2022年03月15日 11:02:01   作者:字母  
这篇文章主要为大家介绍了java并发数据包使用数据交换器Exchanger来进行线程之间的数据交换。有需要的朋友可以借鉴参考下,希望能够有所帮助

java.util.concurrent.Exchanger可以用来进行数据交换,或者被称为“数据交换器”。两个线程可以使用Exchanger交换数据,下图用来说明Exchanger的作用

在下面的代码中

  • 首先我们定义了一个Exchanger,用于数据交换
  • 然后定义了两个线程对象bookExchanger1和bookExchanger2,两个线程都持有Exchanger交换器对象用于数据交换
  • 两个线程中的每个线程都有自己的数据,比如下面代码中的String[] 书籍数组。
public static void main(String[] args) {
  //数据交换器-数据为book
  Exchanger<String> exchanger = new Exchanger<>();
  //换书线程1
  BookExchanger bookExchanger1
          = new BookExchanger(exchanger, new String[]{"Java从入门到放弃","Java编程思想"});
  //换书线程2
  BookExchanger bookExchanger2
          = new BookExchanger(exchanger, new String[]{"C语言程序设计","实战Python数据分析"});
  new Thread(bookExchanger1).start();
  new Thread(bookExchanger2).start();
}

BookExchanger 继承自Runnable代表参与换书的换书读者,他持有Exchanger数据交换器用于交换图书。

public class BookExchanger implements Runnable{
    Exchanger<String> exchanger = null;  //数据交换器
    String[]  books    = null;   //图书数组
    public BookExchanger(Exchanger<String> exchanger, String[] books) {
        this.exchanger = exchanger;
        this.books = books;
    }
    @Override
    public void run() {
        try {
            for(String bookName : books) {
                //交换数据,bookName为我的书,exBook为我换回来的书
                String exBook = this.exchanger.exchange(bookName);
                System.out.println(
                        Thread.currentThread().getName() +
                                " 用《 " + bookName + "》 换 《 " + exBook + "》"
                );
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

执行上文中的代码,得到如下的打印输出。可以看到只有两个线程完成一次交换之后,才能再进行下一次的交换。

Thread-1 用《 C语言程序设计》 换 《 Java从入门到放弃》
Thread-0 用《 Java从入门到放弃》 换 《 C语言程序设计》
Thread-1 用《 实战Python数据分析》 换 《 Java编程思想》
Thread-0 用《 Java编程思想》 换 《 实战Python数据分析》

以上就是java并发数据包Exchanger线程间的数据交换器的详细内容,更多关于java并发Exchanger数据交换的资料请关注脚本之家其它相关文章!

相关文章

  • 在JAVA Web项目中动态加载DLL/SO文件的方法

    在JAVA Web项目中动态加载DLL/SO文件的方法

    在JAVA Web项目中,我们经常需要调用一些第三方库或者实现一些JAVA本身不支持的功能,这时,我们可能会考虑使用JNI来调用DLL或SO文件,然而,因此,本文将介绍如何在JAVA Web项目中动态加载DLL/SO文件,需要的朋友可以参考下
    2024-12-12
  • Java 基于tcp协议实现文件上传

    Java 基于tcp协议实现文件上传

    这篇文章主要介绍了Java 基于tcp协议实现文件上传,帮助大家更好的理解和使用Java,感兴趣的朋友可以了解下
    2020-11-11
  • springboot配置允许跨域访问代码实例

    springboot配置允许跨域访问代码实例

    这篇文章主要介绍了springboot配置允许跨域访问代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-09-09
  • Spring的@Scope注解作用解析

    Spring的@Scope注解作用解析

    这篇文章主要介绍了Spring的@Scope注解作用解析,@Scope注解用于设置实例的作用域,默认值是单实例,即当IOC容器启动后就调用该方法创建对象放到IOC容器中,以后每次获取就是直接从容器中获取,需要的朋友可以参考下
    2023-11-11
  • Spring boot集成Go-FastDFS实现图片上传删除等功能实现

    Spring boot集成Go-FastDFS实现图片上传删除等功能实现

    这篇文章主要介绍了Spring boot集成Go-FastDFS实现图片上传删除等功能实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-04-04
  • Java实现调用jython执行python文件的方法

    Java实现调用jython执行python文件的方法

    这篇文章主要介绍了Java实现调用jython执行python文件的方法,结合实例形式分析了Java调用jython执行python文件的常见操作技巧及相关问题解决方法,需要的朋友可以参考下
    2018-03-03
  • Java基于TCP协议的Socket通信

    Java基于TCP协议的Socket通信

    本文详细讲解了Java基于TCP协议的Socket通信,文中通过示例代码介绍的非常详细。对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-12-12
  • Java判断字符串是否是有效的括号(实例详解)

    Java判断字符串是否是有效的括号(实例详解)

    给定一个只包括 '(',')','{','}','[',']' 的字符串 s ,判断字符串是否有效,有效字符串需要满足:左括号必须用相同类型的右括号闭合,这篇文章主要介绍了Java判断字符串是否是有效的括号,需要的朋友可以参考下
    2023-10-10
  • springboot整合websocket后启动报错(javax.websocket.server.ServerContainer not available)

    springboot整合websocket后启动报错(javax.websocket.server.ServerCont

    这篇文章主要介绍了springboot整合websocket后启动报错(javax.websocket.server.ServerContainer not available),通过分析错误信息、排查代码和配置,找出问题的根源,并给出相应的解决方案,感兴趣的可以了解一下
    2024-01-01
  • java之Objects.nonNull用法代码解读

    java之Objects.nonNull用法代码解读

    这篇文章主要介绍了java之Objects.nonNull用法代码,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2025-03-03

最新评论