Java中JUC?的?Exchange?交換器詳情

更新時(shí)間：2022年05月19日 08:34:52 作者：??Java中文社群????

這篇文章主要介紹了Java中JUC?的?Exchange?交換器詳情，文章基于Java的相關(guān)資料展開詳細(xì)的內(nèi)容介紹，需要的小伙伴可以參考一下

前言

Exchange（交換器）顧名思義，它是用來實(shí)現(xiàn)兩個(gè)線程間的數(shù)據(jù)交換的，它誕生于 JDK 1.5，

它有兩個(gè)核心方法：

exchange(V x)：等待另一個(gè)線程到達(dá)此交換點(diǎn)，然后將對(duì)象傳輸給另一個(gè)線程，并從另一個(gè)線程中得到交換的對(duì)象。如果另一個(gè)線程未到達(dá)此交換點(diǎn)，那么此線程會(huì)一直休眠（除非遇了線程中斷）。
exchange(V x, long timeout, TimeUnit unit)：等待另一個(gè)線程到達(dá)此交換點(diǎn)，然后將對(duì)象傳輸給另一個(gè)線程，并從另一個(gè)線程中得到交換的對(duì)象。如果另一個(gè)線程未到達(dá)此交換點(diǎn)，那么此線程會(huì)一直休眠，直到遇了線程中斷，或等待的時(shí)間超過了設(shè)定的時(shí)間，那么它會(huì)拋出異常。

也就是說 exchange 方法就是一個(gè)交換點(diǎn)，線程會(huì)等待在此交換點(diǎn)，直到有另一個(gè)線程也調(diào)用了 exchange 方法（相當(dāng)于進(jìn)入到了此交換點(diǎn)），這時(shí)他們會(huì)互換數(shù)據(jù)，然后執(zhí)行后續(xù)的代碼。

基礎(chǔ)使用

Exchange 的基礎(chǔ)使用如下，我們創(chuàng)建兩個(gè)線程來模擬“一手交錢、一手交貨”的場(chǎng)景，線程 1 先準(zhǔn)備好錢進(jìn)入交換點(diǎn)，然后等待線程 2 在 2s 之后準(zhǔn)備好貨（物），之后再彼此交互數(shù)據(jù)，執(zhí)行后續(xù)的流程，

具體實(shí)現(xiàn)代碼如下：

import java.time.LocalDateTime;
import java.util.concurrent.Exchanger;
public class ExchangeExample {
    // 創(chuàng)建一個(gè)交互器
    private final static Exchanger<String> exchange = new Exchanger<>();
    public static void main(String[] args) {
        // 線程 1【準(zhǔn)備錢】
        new Thread(() -> {
            System.out.println("線程1：準(zhǔn)備籌錢中...| Time：" + LocalDateTime.now());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            String moeny = "1000 萬";
            System.out.println("線程1：錢準(zhǔn)備好了【1000 萬】。| Time：" + 
                               LocalDateTime.now());
            try {
                // 執(zhí)行數(shù)據(jù)交換【交易】
                String result = exchange.exchange(moeny);
                System.out.println("線程1：交易完成，得到【" + result +
                        "】 | Time：" + LocalDateTime.now());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
        // 線程 2【準(zhǔn)備貨】
        new Thread(() -> {
            System.out.println("線程2：準(zhǔn)備物品中【西伯利亞新鮮空氣】...| Time：" + 
                               LocalDateTime.now());
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            String goods = "西伯利亞新鮮空氣";
            System.out.println("線程2：物品準(zhǔn)備好了【西伯利亞新鮮空氣】。| Time：" + 
                               LocalDateTime.now());
            try {
                // 執(zhí)行數(shù)據(jù)交換【交易】
                String result = exchange.exchange(goods);
                System.out.println("線程2：交易完成，得到【" + result +
                        "】 | Time：" + LocalDateTime.now());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }).start();
    }
}

以上程序的執(zhí)行結(jié)果如下：

總結(jié)

Exchange 交換器是用來實(shí)現(xiàn)兩個(gè)線程間的數(shù)據(jù)交換的，Exchanger 可以交互任意數(shù)據(jù)類型的數(shù)據(jù)，只要在創(chuàng)建的時(shí)候定義泛型類型即可。它的核心方法為 exchange，當(dāng)線程執(zhí)行到此方法之后，會(huì)休眠等待另一個(gè)線程也進(jìn)入交換點(diǎn)，如果另一個(gè)線程也進(jìn)入了交換點(diǎn)（也執(zhí)行到了 exchange 方法），此時(shí)二者會(huì)交換數(shù)據(jù)，并執(zhí)行后續(xù)的流程。

到此這篇關(guān)于Java中JUC 的 Exchange 交換器詳情的文章就介紹到這了,更多相關(guān)Exchange 交換器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: