快捷導航

Java高并發(fā)中的交換器Exchanger解析

更新時間：2023年12月02日 10:07:34 作者：safe_u

這篇文章主要介紹了Java高并發(fā)中的交換器Exchanger解析,如果兩個線程并行處理,但在某個時刻需要互相交換自己已經(jīng)處理完的中間數(shù)據(jù),然后才能繼續(xù)往下執(zhí)行,這個時候就可以使用 Exchanger,需要的朋友可以參考下

1.Exchanger簡介

Exchanger — 交換器，是JDK1.5時引入的一個同步器，從字面上就可以看出，這個類的主要作用是交換數(shù)據(jù)。

如果兩個線程并行處理，但在某個時刻需要互相交換自己已經(jīng)處理完的中間數(shù)據(jù)，然后才能繼續(xù)往下執(zhí)行。這個時候就可以使用 Exchanger。

Thread1線程到達柵欄后，會首先觀察有沒其它線程已經(jīng)到達柵欄，如果沒有就會等待，如果已經(jīng)有其它線程（Thread2）已經(jīng)到達了，就會以成對的方式交換各自攜帶的信息，因此Exchanger非常適合用于兩個線程之間的數(shù)據(jù)交換。

2.Exchanger的使用

2.1 常用方法

//實現(xiàn)數(shù)據(jù)交換，x是交換的數(shù)據(jù)，V是返回對方線程傳遞的數(shù)據(jù)
public V exchange(V x) throws InterruptedException
?
//用于交換，啟動交換并等待另一個線程調(diào)用exchange，并且設(shè)置最大等待時間，當?shù)却龝r間超過timeout便停止等待。
public V exchange(V x, long timeout, TimeUnit unit)

2.2 使用舉例

//數(shù)據(jù)交換器，用于數(shù)據(jù)交換
        Exchanger<String> exchanger = new Exchanger<>();
?
        //換書線程1
        new Thread(()->{
            String[] books_A = new String[]{"C++","操作系統(tǒng)"};//圖書數(shù)組
            for (String bookNameA:books_A) {
                try {
                    //交換數(shù)據(jù)，bookNameA為我的書，exBook_A為我換回來的書
                    //System.out.println("線程A準備提交《"+bookNameA+"》書籍，等待交換...");
                    String exBook_A = exchanger.exchange(bookNameA);
                    System.out.println(Thread.currentThread().getName()+" 用 《"+bookNameA+"》換《"+exBook_A+"》");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
?
        },"線程A").start();
?
        //換書線程2
        new Thread(()->{
            String[] books_B = new String[]{"Java攻略","并發(fā)編程"};//圖書數(shù)組
            for (String bookNameB:books_B) {
                try {
                    String exBook_B = exchanger.exchange(bookNameB);
                    System.out.println(Thread.currentThread().getName()+" 用 《"+bookNameB+"》換《"+exBook_B+"》");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"線程B").start();