Java高并发中的交换器Exchanger解析

//实现数据交换，x是交换的数据，V是返回对方线程传递的数据
public V exchange(V x) throws InterruptedException
​
//用于交换，启动交换并等待另一个线程调用exchange，并且设置最大等待时间，当等待时间超过timeout便停止等待。
public V exchange(V x, long timeout, TimeUnit unit)

//数据交换器，用于数据交换
        Exchanger<String> exchanger = new Exchanger<>();
​
        //换书线程1
        new Thread(()->{
            String[] books_A = new String[]{"C++","操作系统"};//图书数组
            for (String bookNameA:books_A) {
                try {
                    //交换数据，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攻略","并发编程"};//图书数组
            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();