前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Java Concurrent Exchanger

Java Concurrent Exchanger

作者头像
邹志全
发布2019-07-31 10:59:30
2960
发布2019-07-31 10:59:30
举报

前言

Exchanger是JUC里提供的供两个线程之间交换数据或者交互的一个并发工具,API也非常简单就两个重载的exchange泛型方法。

使用的场景

通常用于将写读任务与任务逻辑处理任务分开,一个专门处理、一个专门操作。当一个线程带着数据调用exchange方法后,除非中断到达时间等,否则会一直等在另一个线程,并接受其数据。 看一下demo:

import java.util.concurrent.Exchanger;
public class ExchangerDemo {
    static Exchanger exchanger = new Exchanger();
    static void startReadThread(){
        new Thread(new Runnable() {
            @Override
            public void run() {
                String temp="23333";
                System.out.println("ThreadA temp:"+temp);
                for(int i=0;i<10;i++){
                    System.out.println("线程A 已执行"+i+"秒");
                    if (i==4){
                        try {
                            temp= (String) exchanger.exchange(temp);
                            System.out.println("发生数据交换");
                            System.out.println("ThreadA temp:"+temp);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }
    static void startOperateThread(){
        new Thread(new Runnable() {
            @Override
            public void run() {
                String temp="11111111";
                System.out.println("ThreadB temp:"+temp);
                for(int i=0;i<10;i++){
                    System.out.println("线程B 已执行"+i+"秒");
                    if (i==9){
                        try {
                            temp= (String) exchanger.exchange(temp);
                            System.out.println("发生数据交换");
                            System.out.println("ThreadB temp:"+temp);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                    }
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }
    public static void main(String []args) {
        startReadThread();
        startOperateThread();
    }
}

核心的实现函数就这两个,有兴趣可以看看。 arenaExchange(Object item, boolean timed, long ns) slotExchange(Object item, boolean timed, long ns)

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2019.07.17 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 前言
  • 使用的场景
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档