当前位置：首页 > 文章列表 > 文章 > java教程 > Java并发Exchanger详解与使用教程

Java并发Exchanger详解与使用教程

2026-02-13 12:58:58 0浏览收藏

一分耕耘，一分收获！既然都打开这篇《Java并发Exchanger使用详解》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新文章相关的内容，希望对大家都有所帮助！

Exchanger是Java中用于两个线程交换数据的工具，通过exchange()方法在汇合点互换对象，支持超时设置，适用于双线程协同场景。

Java并发编程中Exchanger使用方法

在Java并发编程中，Exchanger 是一个用于两个线程之间交换数据的同步工具类。它位于 java.util.concurrent 包下，允许两个线程在某个汇合点交换各自持有的对象，非常适合双向数据传递的场景。

Exchanger 的基本原理

Exchanger 是一个泛型类，V 表示要交换的数据类型。两个线程分别调用 exchange(V data) 方法，当第一个线程调用时会等待，直到第二个线程也调用该方法，此时两个线程交换数据并继续执行。

这种机制类似于“碰头交易”：两个线程各带一份数据，在约定地点交换后离开。

简单使用示例

下面是一个使用 Exchanger 在两个线程间交换字符串的例子：

import java.util.concurrent.Exchanger;

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

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

输出结果可能是：

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

带超时的 exchange 方法

除了基本的 exchange(V data)，Exchanger 还提供了一个带超时时间的方法：
exchange(V data, long timeout, TimeUnit unit)。

如果在指定时间内没有另一个线程来交换数据，该方法将抛出 TimeoutException 或返回 null（取决于实现），避免无限等待。

例如：

try {
    String received = exchanger.exchange(data, 5, TimeUnit.SECONDS);
} catch (InterruptedException | TimeoutException e) {
    System.err.println("交换超时或被中断");
}