Java如何使用Exchanger在线程间交换数据_Java双线程协作模型-java教程-PHP中文网

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

java如何使用exchanger在线程间交换数据_java双线程协作模型

在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<string> 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 <p>输出可能如下：</p><div class="aritcle_card flexRow artxards">
											<div class="artcardd flexRow">
												<a class="aritcle_card_img" rel="nofollow" href="/xiazai/gongju/2495" title="ApiPost接口调试与文档生成工具"><img
														src="https://img.php.cn/upload/manual/000/000/020/178471622538733.png" alt="ApiPost接口调试与文档生成工具" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
												<div class="aritcle_card_info flexColumn">
													<a rel="nofollow" href="/xiazai/gongju/2495" title="ApiPost接口调试与文档生成工具" class="overflowclass">ApiPost接口调试与文档生成工具</a>
													<p class="overflowclass">ApiPost是一个支持团队协作，支持模拟POST、GET、PUT等常见请求，并可直接生成文档的API调试、管理工具，ApiPost是后台接口开发者或前端、接口测试人员的工作必备工具。快速生成、一键导出API文档。感兴趣的朋友快来下载吧。软件说明ApiPost官方版是一款十分出色的接口调试与文档生成工具，ApiPost官方版界面美观大方，功能强劲实用，支持团队协作，支持模拟POST、GET、PUT等常见请求，是后台接口开发者或前端、接口测试人员的工作必备工具。软件特色更方便支持接口调试的同时快速生成、一键</p>
												</div>
												<a rel="nofollow" href="/xiazai/gongju/2495" title="ApiPost接口调试与文档生成工具" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
												</a>
											</div>
										</div>
<pre class="brush:php;toolbar:false;">
生产者准备发送: 消息1
消费者收到: 消息1
生产者收到反馈: 已处理
生产者准备发送: 消息2
消费者收到: 消息2
生产者收到反馈: 已处理
...

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