java併發編程JUC第十一篇:如何在線程之間進行對等數據交換

java.util.concurrent.Exchanger能夠用來進行數據交換,或者被稱爲「數據交換器」。兩個線程可使用Exchanger交換數據,下圖用來講明Exchanger的做用vue

在下面的代碼中java

  • 首先咱們定義了一個Exchanger,用於數據交換
  • 而後定義了兩個線程對象bookExchanger1和bookExchanger2,兩個線程都持有Exchanger交換器對象用於數據交換
  • 兩個線程中的每一個線程都有本身的數據,好比下面代碼中的String[] 書籍數組。spring

    public static void main(String[] args) {
    //數據交換器-數據爲book
    Exchanger<String> exchanger = new Exchanger<>();
    //換書線程1
    BookExchanger bookExchanger1
            = new BookExchanger(exchanger, new String[]{"Java從入門到放棄","Java編程思想"});
    //換書線程2
    BookExchanger bookExchanger2
            = new BookExchanger(exchanger, new String[]{"C語言程序設計","實戰Python數據分析"});
    
    new Thread(bookExchanger1).start();
    new Thread(bookExchanger2).start();
    }

BookExchanger 繼承自Runnable表明參與換書的換書讀者,他持有Exchanger數據交換器用於交換圖書。編程

public class BookExchanger implements Runnable{

    Exchanger<String> exchanger = null;  //數據交換器
    String[]  books    = null;   //圖書數組

    public BookExchanger(Exchanger<String> exchanger, String[] books) {
        this.exchanger = exchanger;
        this.books = books;
    }

    @Override
    public void run() {
        try {
            for(String bookName : books) {
                //交換數據,bookName爲個人書,exBook爲我換回來的書
                String exBook = this.exchanger.exchange(bookName);
                System.out.println(
                        Thread.currentThread().getName() +
                                " 用《 " + bookName + "》 換 《 " + exBook + "》"
                );
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

執行上文中的代碼,獲得以下的打印輸出。能夠看到只有兩個線程完成一次交換以後,才能再進行下一次的交換。後端

Thread-1 用《 C語言程序設計》 換 《 Java從入門到放棄》
Thread-0 用《 Java從入門到放棄》 換 《 C語言程序設計》
Thread-1 用《 實戰Python數據分析》 換 《 Java編程思想》
Thread-0 用《 Java編程思想》 換 《 實戰Python數據分析》

歡迎關注個人博客,裏面有不少精品合集

本文轉載註明出處(必須帶鏈接,不能只轉文字):字母哥博客 - zimug.com數組

以爲對您有幫助的話,幫我點贊、分享!您的支持是我不竭的創做動力! 。另外,筆者最近一段時間輸出了以下的精品內容,期待您的關注。springboot

相關文章
相關標籤/搜索