Java如何使用Exchanger在线程间交换数据_Java双线程协作模型

Exchanger是Java中用于两个线程间交换数据的同步工具，通过exchange()方法实现双向数据传递。两个线程调用exchange()时阻塞，直至双方到达后完成数据交换，支持超时机制避免永久等待。示例中生产者发送消息，消费者返回确认，实现协作处理。适用于双缓冲、对战游戏等成对线程协作场景，但仅限两线程使用，需注意异常导致的阻塞风险。

在Java多线程编程中，Exchanger 是一个用于两个线程之间交换数据的同步工具类，位于 java.util.concurrent 包中。它提供了一种简单而高效的双线程协作模型：两个线程通过调用 exchange() 方法，各自传递一个对象，在双方都到达交换点时，数据自动完成交换。

Exchanger的基本原理

Exchanger可以看作是一个“会合点”。两个线程分别执行到 exchange() 调用时会阻塞，直到另一个线程也调用了 exchange()，此时两者的数据进行交换并继续执行。如果只有一个线程调用，它将一直等待，除非设置超时（使用带超时参数的方法）。

主要方法：

• V exchange(V x)：等待另一个线程到达交换点，并交换数据。
• V exchange(V x, long timeout, TimeUnit unit)：在指定时间内等待交换，超时则抛出 TimeoutException。

实际使用示例

下面是一个简单的双线程数据交换场景：生产者线程生成数据放入缓冲区，消费者线程取出数据处理，二者通过 Exchanger 协作交换缓冲区引用。

import java.util.concurrent.Exchanger;

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

        Thread producer = new Thread(() -> {
            String[] data = {"消息1", "消息2", "消息3"};
            for (String msg : data) {
                try {
                    System.out.println("生产者准备发送: " + msg);
                    String received = exchanger.exchange(msg); // 发送自己的数据，接收对方的
                    System.out.println("生产者收到反馈: " + received);
                    Thread.sleep(500);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });

        Thread consumer = new Thread(() -> {
            for (int i = 0; i < 3; i++) {
                try {
                    String received = exchanger.exchange("已处理"); // 发送确认，接收数据
                    System.out.println("消费者收到: " + received);
                    Thread.sleep(800);
                } catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                }
            }
        });

        producer.start();
        consumer.start();
    }
}

输出可能如下：

生产者准备发送: 消息1
消费者收到: 消息1
生产者收到反馈: 已处理
生产者准备发送: 消息2
消费者收到: 消息2
生产者收到反馈: 已处理
...

可以看到，每次 exchange() 调用都会触发一次双向数据传递，实现了线程间的对等协作。

适用场景与注意事项

适用场景：

• 双人对战游戏中的状态同步。
• 流水线式处理中，两个线程交替处理并交换缓冲区（如双缓冲机制）。
• 需要成对协作的任务，比如数据校验、配对计算等。

注意事项：

• Exchanger只支持两个线程之间的交换，多于两个线程的行为不可预测。
• 若一个线程提前退出或异常，另一个线程可能永久阻塞，需谨慎处理中断和超时。
• 交换的数据类型由泛型定义，建议保持一致以避免类型错误。

基本上就这些。Exchanger虽然使用场景有限，但在特定的双线程协作模型中非常简洁高效。合理利用它可以减少锁和条件变量的复杂性，提升代码可读性和性能。不复杂但容易忽略。