Java多线程：Exchanger如何交换数据

Exchanger 是 Java 并发包 java.util.concurrent 中的一个类，它提供了一种在两个线程之间交换数据的机制。当两个线程都调用 exchange() 方法时，它们会互相等待，直到其中一个线程到达交换点。一旦一个线程到达交换点，它会将自己的数据传递给另一个线程，并接收另一个线程的数据。

下面是一个简单的示例，演示了如何使用 Exchanger 在两个线程之间交换数据：

import java.util.concurrent.Exchanger;

public class ExchangerExample {

    public static void main(String[] args) {
        Exchanger<String> exchanger = new Exchanger<>();

        Thread t1 = new Thread(new ExchangeTask(exchanger, "Hello from Thread 1"));
        Thread t2 = new Thread(new ExchangeTask(exchanger, "Hello from Thread 2"));

        t1.start();
        t2.start();
    }

    static class ExchangeTask implements Runnable {
        private final Exchanger<String> exchanger;
        private final String data;

        public ExchangeTask(Exchanger<String> exchanger, String data) {
            this.exchanger = exchanger;
            this.data = data;
        }

        @Override
        public void run() {
            try {
                System.out.println(Thread.currentThread().getName() + " is ready to exchange data.");
                String receivedData = exchanger.exchange(data);
                System.out.println(Thread.currentThread().getName() + " received data: " + receivedData);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

在这个示例中，我们创建了一个 Exchanger 实例，然后创建了两个线程 t1 和 t2。每个线程都执行 ExchangeTask 任务，该任务接收一个 Exchanger 实例和一个字符串数据。当两个线程都调用 exchange() 方法时，它们会互相等待，直到其中一个线程到达交换点。一旦一个线程到达交换点，它会将自己的数据传递给另一个线程，并接收另一个线程的数据。

运行这个示例，你可能会看到类似以下的输出：

Thread-0 is ready to exchange data.
Thread-1 is ready to exchange data.
Thread-1 received data: Hello from Thread 1
Thread-0 received data: Hello from Thread 2

请注意，由于线程调度和执行的不确定性，输出可能会有所不同。但是，你可以看到两个线程成功地交换了数据。