Exchanger?

• 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ì)方（只能在兩個(gè)線程之間交換數(shù)據(jù)）

使用場(chǎng)景

• 遺傳算法：遺傳算法里需要選出兩個(gè)人作為交換對(duì)象，這時(shí)會(huì)交換兩人的數(shù)據(jù)，并使用交叉規(guī)則得出兩個(gè)人交換結(jié)果。
• 校對(duì)工作：A、B同時(shí)錄入數(shù)據(jù)，然后對(duì)A、B進(jìn)行比較，看是否錄入一致，保證數(shù)據(jù)正確性

package com.example.core.juc;import org.springframework.jmx.export.naming.IdentityNamingStrategy;import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;public class UseExchanger {private static final Exchanger<String> exchanger = new Exchanger<>();//Exchanger<String>交換String類(lèi)型//Exchanger用于兩個(gè)數(shù)據(jù)之間的數(shù)據(jù)交換private static ExecutorService executorService = Executors.newFixedThreadPool(2);public static void main(String[] args) {executorService.execute(new Runnable() {@Overridepublic void run() {String A = "銀行流水A";try{String B = exchanger.exchange(A);//交換我自己的數(shù)據(jù)，并且獲取別人的數(shù)據(jù)System.out.println("線程A："+B);}catch (InterruptedException w){w.printStackTrace();}}});executorService.execute(new Runnable() {@Overridepublic void run() {String B = "銀行流水B";try{String A = exchanger.exchange(B);//交換我自己的數(shù)據(jù)，并且獲取別人的數(shù)據(jù)System.out.println("線程B："+A);}catch (InterruptedException w){w.printStackTrace();}}});executorService.shutdown();//關(guān)閉線程池} } /* output: 線程B：銀行流水A 線程A：銀行流水B*/

?

總結(jié)

以上是生活随笔為你收集整理的Java JUC工具类--Exchanger的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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