Java 并发编程之Exchanger（两方栅栏）

左手的ㄟ右手 2023-10-07 08:13 40阅读 0赞

## `一、Exchanger` ##

> Exchanger,它是一种两方(Two-Party)栅栏，各方在栅栏位置上交换数据。当两方执行不对称的操作时，Exchanger会非常有用，例如当一个线程向缓 冲区写入数据，而另一个线程从缓冲区中读取数据。这些线程可以使用Exchanger来汇合，并 将满的缓冲区与空的缓冲区交换。当两个线程通过Exchanger交换对象时，这种交换就把这两 个对象安全地发布给另一方。  
>   
> Exchanger 可以用于两个工作线程之间交换数据，简单说就是一个线程在完成一定的事务后想与另一个线程交换数据，则第一个先拿出数据（第一个执行exchange方法）的线程会一直等待第二个线程，直到第二个线程拿着数（第二个执行exchange方法）据到来时才能彼此交换对应数据。

## `二、常用方法` ##

<table> 
 <thead> 
  <tr> 
   <th align="left">方法</th> 
   <th align="left">描述</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td align="left">V exchange(V x)</td> 
   <td align="left">等待另一个线程到达此交换点（除非当前线程被中断），然后将给定对象传输到该交换点，以接收其返回的对象。</td> 
  </tr> 
  <tr> 
   <td align="left">V exchange(V x, long timeout, TimeUnit unit)</td> 
   <td align="left">等待另一个线程到达此交换点（除非当前线程被中断或经过了指定的等待时间），然后将给定的对象传送给该对象，并返回其对象。</td> 
  </tr> 
 </tbody> 
</table>

## `三、示例` ##

public static void main(String[] args) {
        
    
        Exchanger<String> exchanger = new Exchanger<>();
    
        Thread threadA = new Thread(new Runnable() {
        
            @Override
            public void run() {
        
                try {
        
                    String message = exchanger.exchange("B你好呀!");
                    System.out.println("A收到消息：" + message);
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                }
            }
        });
    
        Thread threadB = new Thread(new Runnable() {
        
            @Override
            public void run() {
        
                try {
        
                    String message = exchanger.exchange("A你也好呀!");
                    System.out.println("B收到消息：" + message);
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                }
            }
        });
    
        threadA.start();
        threadB.start();
    }