Java并發(fā)工具之Exchanger線程間交換數(shù)據(jù)詳解

更新時間：2023年12月11日 09:30:25 作者：warybee

這篇文章主要介紹了Java并發(fā)工具之Exchanger線程間交換數(shù)據(jù)詳解,Exchanger是一個用于線程間協(xié)作的工具類,Exchanger用于進行線程間的數(shù)據(jù)交換,它提供一個同步點,在這個同步點,兩個線程可以交換彼此的數(shù)據(jù),需要的朋友可以參考下

Exchanger簡介

Exchanger是一個用于線程間協(xié)作的工具類。

Exchanger用于進行線程間的數(shù)據(jù)交換。

它提供一個同步點，在這個同步點，兩個線程可以交換彼此的數(shù)據(jù)。

這兩個線程通過 exchange方法交換數(shù)據(jù)，如果第一個線程先執(zhí)行exchange()方法，它會一直等待第二個線程也執(zhí)行exchange()方法，當兩個線程都到達同步點時，這兩個線程就可以交換數(shù)據(jù)，將本線程生產(chǎn) 出來的數(shù)據(jù)傳遞給對方

在這里插入圖片描述

Exchanger使用介紹

Exchanger<T>用于在兩個線程之間共享數(shù)據(jù)。該類僅提供一個重載方法exchange(T t)，其中exchange(V x, long timeout, TimeUnit unit)方法可以指定阻塞超時時間，下面通過一個來理解兩個線程之間交換數(shù)據(jù)：

public class ExchangerDemo {
    static Exchanger<String> exgr = new Exchanger<>();
    public static void main(String[] args) {
         Thread taskA=new Thread(()->{
             try {
                 String message = exgr.exchange("from A");
                 System.out.println("A Task===>"+ message);
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
         });
        Thread taskB=new Thread(()->{
            try {
                String message = exgr.exchange("from B");
                System.out.println("B Task===>"+ message);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });
        taskA.start();
        taskB.start();

    }
}

輸出結(jié)果：

線程A，把數(shù)據(jù)傳給了線程B，線程B，把數(shù)據(jù)傳給了線程A

B Task===>from A
A Task===>from B

子線程與主線程間交換數(shù)據(jù)

public class ExchangerDemo2 {
    static Exchanger<String> exchanger = new Exchanger<>();
    public static void main(String[] args) throws InterruptedException {
        Runnable childTask = () -> {
            try {
                String message = exchanger.exchange("來自子線程的數(shù)據(jù)");
                System.out.println("子線程： "+message);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                throw new RuntimeException(e);
            }
        };
        //CompletableFuture java1.8中新增的異步編程類
        CompletableFuture<Void> result = CompletableFuture.runAsync(childTask);
        String msg = exchanger.exchange(" 來自主線程的數(shù)據(jù)");
        System.out.println("主線程： " +msg);
        result.join();
    }
}

輸出結(jié)果：