快捷導(dǎo)航

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

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

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

1.Exchanger簡(jiǎn)介

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

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

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

2.Exchanger的使用

2.1 常用方法

//實(shí)現(xiàn)數(shù)據(jù)交換，x是交換的數(shù)據(jù)，V是返回對(duì)方線程傳遞的數(shù)據(jù)
public V exchange(V x) throws InterruptedException
?
//用于交換，啟動(dòng)交換并等待另一個(gè)線程調(diào)用exchange，并且設(shè)置最大等待時(shí)間，當(dāng)?shù)却龝r(shí)間超過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準(zhǔn)備提交《"+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();