快捷導(dǎo)航

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

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

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

Exchanger簡介

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

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

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

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

在這里插入圖片描述

Exchanger使用介紹

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

子線程：來自主線程的數(shù)據(jù)
主線程：來自子線程的數(shù)據(jù)

到此這篇關(guān)于Java并發(fā)工具之Exchanger線程間交換數(shù)據(jù)詳解的文章就介紹到這了,更多相關(guān)Exchanger線程間交換數(shù)據(jù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: