簡(jiǎn)介

Exchanger（交換者）是一個(gè)用于線程間協(xié)作的工具類(lèi)。Exchanger用于進(jìn)行線程間的數(shù)據(jù)交換。它提供一個(gè)同步點(diǎn)，在這個(gè)同步點(diǎn)兩個(gè)線程可以交換彼此的數(shù)據(jù)。這兩個(gè)線程通過(guò)exchange方法交換數(shù)據(jù)， 如果第一個(gè)線程先執(zhí)行exchange方法，它會(huì)一直等待第二個(gè)線程也執(zhí)行exchange，當(dāng)兩個(gè)線程都到達(dá)同步點(diǎn)時(shí)，這兩個(gè)線程就可以交換數(shù)據(jù)，將本線程生產(chǎn)出來(lái)的數(shù)據(jù)傳遞給對(duì)方。

Exchanger的應(yīng)用場(chǎng)景

Exchanger可以用于遺傳算法，遺傳算法里需要選出兩個(gè)人作為交配對(duì)象，這時(shí)候會(huì)交換兩人的數(shù)據(jù)，并使用交叉規(guī)則得出2個(gè)交配結(jié)果。
Exchanger也可以用于校對(duì)工作。比如我們需要將紙制銀流通過(guò)人工的方式錄入成電子銀行流水，為了避免錯(cuò)誤，采用AB崗兩人進(jìn)行錄入，錄入到Excel之后，系統(tǒng)需要加載這兩個(gè)Excel，并對(duì)這兩個(gè)Excel數(shù)據(jù)進(jìn)行校對(duì)，看看是否錄入的一致。代碼如下：

01	public?class?ExchangerTest {

02

?

03	????private?static?final?Exchanger<String> exgr =?new?Exchanger<String>();

04

?

05	????private?static?ExecutorService threadPool = Executors.newFixedThreadPool(2);

06

?

07	????public?static?void?main(String[] args) {

08

?

09	????????threadPool.execute(new?Runnable() {

10	????????????@Override

11	????????????public?void?run() {

12	????????????????try?{

13	????????????????????String A =?"銀行流水A";// A錄入銀行流水?dāng)?shù)據(jù)

14	????????????????????exgr.exchange(A);

15	????????????????}?catch?(InterruptedException e) {

16	????????????????}

17	????????????}

18	????????});

19

?

20	????????threadPool.execute(new?Runnable() {

21	????????????@Override

22	????????????public?void?run() {

23	????????????????try?{

24	????????????????????String B =?"銀行流水B";// B錄入銀行流水?dāng)?shù)據(jù)

25	????????????????????String A = exgr.exchange("B");

26	????????????????????System.out.println("A和B數(shù)據(jù)是否一致："?+ A.equals(B) +?",A錄入的是："

27	????????????????????????????+ A +?",B錄入是："?+ B);

28	????????????????}?catch?(InterruptedException e) {

29	????????????????}

30	????????????}

31	????????});

32

?

33	????????threadPool.shutdown();

34

?

35

????}

36

}

其他方法

如果兩個(gè)線程有一個(gè)沒(méi)有到達(dá)exchange方法，則會(huì)一直等待,如果擔(dān)心有特殊情況發(fā)生，避免一直等待，可以使用exchange(V x, long timeout, TimeUnit unit)設(shè)置最大等待時(shí)長(zhǎng)。

原創(chuàng)文章，轉(zhuǎn)載請(qǐng)注明：?轉(zhuǎn)載自并發(fā)編程網(wǎng) – ifeve.com本文鏈接地址:?并發(fā)工具類(lèi)（四）兩個(gè)線程進(jìn)行數(shù)據(jù)交換的Exchanger

總結(jié)

以上是生活随笔為你收集整理的并发工具类（四）两个线程进行数据交换的Exchanger的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。