Java中Exchanger类使用方法-java教程-PHP中文网

Java中Exchanger类使用方法

P粉602998670

发布： 2025-09-27 12:23:01

原创

638人浏览过

Exchanger用于两个线程间交换数据，调用exchange()方法时双方阻塞直至完成数据交换，适用于双缓冲、任务结果互传等场景，支持超时机制避免无限等待，需注意仅限两线程使用以防配对混乱。

java中exchanger类使用方法

Exchanger 是 Java 并发包 java.util.concurrent 中的一个工具类，用于两个线程之间交换数据。它提供了一个同步点，两个线程可以在此处交换各自持有的对象。当一个线程调用 exchange() 方法时，它会等待另一个线程也调用该方法，然后两者交换数据并继续执行。

基本使用场景

Exchanger 适用于两个线程需要双向传递数据的场景，比如生产者和消费者之间批量交换缓冲区，或者两个协作线程交换任务结果。

关键方法是 exchange(V x)，它会阻塞直到另一个线程也调用 exchange()。

示例代码：

立即学习“Java免费学习笔记（深入）”；

下面是一个简单的例子，两个线程分别生成数据，并通过 Exchanger 交换它们的内容：

import java.util.concurrent.Exchanger;

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

        new Thread(() -> {
            String data = "来自线程 A 的数据";
            try {
                System.out.println("线程 A 准备交换...");
                String received = exchanger.exchange(data);
                System.out.println("线程 A 接收到: " + received);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }, "Thread-A").start();

        new Thread(() -> {
            String data = "来自线程 B 的数据";
            try {
                System.out.println("线程 B 准备交换...");
                String received = exchanger.exchange(data);
                System.out.println("线程 B 接收到: " + received);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }, "Thread-B").start();
    }
}

登录后复制

输出可能为：

法语写作助手

法语助手旗下的AI智能写作平台，支持语法、拼写自动纠错，一键改写、润色你的法语作文。

查看详情

线程 A 准备交换...
线程 B 准备交换...
线程 A 接收到: 来自线程 B 的数据
线程 B 接收到: 来自线程 A 的数据

登录后复制

带超时的交换

Exchanger 还支持设置超时的 exchange 方法：exchange(V x, long timeout, TimeUnit unit)。如果在指定时间内没有另一个线程参与交换，会抛出 TimeoutException。

这适合对响应时间有要求的场景。

示例：使用超时机制

import java.util.concurrent.*;

new Thread(() -> {
    try {
        String result = exchanger.exchange("Data from C", 2, TimeUnit.SECONDS);
        System.out.println("线程 C 收到: " + result);
    } catch (InterruptedException | TimeoutException e) {
        System.out.println("线程 C 等待超时或被中断");
    }
}).start();

登录后复制

使用注意事项

Exchanger 只设计用于两个线程之间的数据交换。如果多个线程调用 exchange()，不能保证哪两个线程会配对成功，可能导致不可预期的行为。

确保只让两个线程使用同一个 Exchanger 实例进行配对交换。
exchange() 方法是阻塞的，注意线程生命周期管理，避免死锁或无限等待。
交换的数据对象由开发者自行管理线程安全，Exchanger 本身不处理对象内部的并发问题。

基本上就这些。Exchanger 使用简单，但在特定协作场景下非常有用，比如双缓冲切换、线程间状态同步等。

以上就是Java中Exchanger类使用方法的详细内容，更多请关注php中文网其它相关文章！