簡介

Exchanger是一個用于線程間數據交換的工具類，它提供一個公共點，在這個公共點，兩個線程可以交換彼此的數據。

當一個線程調用exchange方法后將進入等待狀態，直到另外一個線程調用exchange方法，雙方完成數據交換后繼續執行。

Exchanger的使用方法介紹

exchange(V x)：阻塞當前線程，直到另外一個線程調用exchange方法或者當前線程被中斷。

x : 需要交換的對象。

exchange(V x, long timeout, TimeUnit unit)：阻塞當前線程，直到另外一個線程調用exchange方法或者當前線程被中斷或者等待超時。

x: 需要交換的對象。 timeout：超時時間。 unit：超時時間單位。

exchange方法正常情況返回交換到的對象，當當前線程被中斷或者等待超時時，exchange方法返回null。

示例1：A同學和B同學交換各自收藏的大片

public class Demo { public static void main(String[] args) {Exchanger<String> stringExchanger = new Exchanger<>();Thread studentA = new Thread(() -> { try {String dataA = 'A同學收藏多年的大片';String dataB = stringExchanger.exchange(dataA);System.out.println('A同學得到了' + dataB); } catch (InterruptedException e) {e.printStackTrace(); }});Thread studentB = new Thread(() -> { try {String dataB = 'B同學收藏多年的大片';String dataA = stringExchanger.exchange(dataB);System.out.println('B同學得到了' + dataA); } catch (InterruptedException e) {e.printStackTrace(); }});studentA.start();studentB.start(); }}/* * 輸出結果： * B同學得到了A同學收藏多年的大片 * A同學得到了B同學收藏多年的大片 */

示例2：A同學被放鴿子，交易失敗

public class Demo { public static void main(String[] args) {Exchanger<String> stringExchanger = new Exchanger<>();Thread studentA = new Thread(() -> { String dataB = null; try {String dataA = 'A同學收藏多年的大片';//最多等待5秒dataB = stringExchanger.exchange(dataA, 5, TimeUnit.SECONDS); } catch (InterruptedException e) {e.printStackTrace(); } catch (TimeoutException ex){System.out.println('等待超時-TimeoutException'); } System.out.println('A同學得到了' + dataB);});studentA.start(); }}/* * 輸出結果： * 等待超時-TimeoutException * A同學得到了null */

到此這篇關于Java并發編程之Exchanger方法詳解的文章就介紹到這了,更多相關Java并發編程Exchanger內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網！