本篇文章,我將和大家簡單地分享一下關(guān)于 Java 并發(fā)編程中的 Exchanger 方法,以及用 Java 實例代碼來展示該方法的具體使用方法。下面是詳情內(nèi)容。
簡介
Exchanger是一個用于線程間數(shù)據(jù)交換的工具類,它提供一個公共點,在這個公共點,兩個線程可以交換彼此的數(shù)據(jù)。
當(dāng)一個線程調(diào)用exchange方法后將進入等待狀態(tài),直到另外一個線程調(diào)用exchange方法,雙方完成數(shù)據(jù)交換后繼續(xù)執(zhí)行。
Exchanger的使用
方法介紹
exchange(V x):阻塞當(dāng)前線程,直到另外一個線程調(diào)用exchange方法或者當(dāng)前線程被中斷。
- x : 需要交換的對象。
exchange(V x, long timeout, TimeUnit unit):阻塞當(dāng)前線程,直到另外一個線程調(diào)用exchange方法或者當(dāng)前線程被中斷或者等待超時。
- x: 需要交換的對象。
- timeout:超時時間。
- unit:超時時間單位。
exchange方法正常情況返回交換到的對象,當(dāng)當(dāng)前線程被中斷或者等待超時時,exchange方法返回null。
示例1:A同學(xué)和B同學(xué)交換各自收藏的大片
public class Demo {
public static void main(String[] args) {
Exchanger<String> stringExchanger = new Exchanger<>();
Thread studentA = new Thread(() -> {
try {
String dataA = "A同學(xué)收藏多年的大片";
String dataB = stringExchanger.exchange(dataA);
System.out.println("A同學(xué)得到了" + dataB);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
Thread studentB = new Thread(() -> {
try {
String dataB = "B同學(xué)收藏多年的大片";
String dataA = stringExchanger.exchange(dataB);
System.out.println("B同學(xué)得到了" + dataA);
} catch (InterruptedException e) {
e.printStackTrace();
}
});
studentA.start();
studentB.start();
}
}
/*
* 輸出結(jié)果:
* B同學(xué)得到了A同學(xué)收藏多年的大片
* A同學(xué)得到了B同學(xué)收藏多年的大片
*/
示例2:A同學(xué)被放鴿子,交易失敗
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同學(xué)收藏多年的大片";
//最多等待5秒
dataB = stringExchanger.exchange(dataA, 5, TimeUnit.SECONDS);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (TimeoutException ex){
System.out.println("等待超時-TimeoutException");
}
System.out.println("A同學(xué)得到了" + dataB);
});
studentA.start();
}
}
/*
* 輸出結(jié)果:
* 等待超時-TimeoutException
* A同學(xué)得到了null
*/
到此這篇關(guān)于 Java 并發(fā)編程 中的 Exchanger 方法詳解的文章就介紹到這了,想要了解更多相關(guān) Java 并發(fā)編程的其他內(nèi)容請搜索W3Cschool以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持!