本文将带你了解exchange服务器之Java多线程 -- JUC包源码分析16 -- Exchanger源码分析，希望本文对大家学Exchange有所帮助。

今天所讲的Exchange，顾明思义，是双向的数据传输，2个线程在一个同步点，交换数据。

其使用方式，大致如下：



Exchange exchange = new Exchange(); //建1个多个线程共用的exchange对象

//把exchange对象，传给4个线程对象。每个线程在自己的run函数里面，调用exchange，把自己的数据当参数传进去，返回值是另外一个线程调用exchange塞进去的参数。
ThreadA a = new ThreadA(exchange);
run()
{
   String other = exchange.exchange(self.data)  //没有别的线程调用exchange的话，自己会阻塞在这。直到有别的线程调用exchange。
}


ThreadB b = new ThreadB(exchange);
run()
{
   String other = exchange.exchange(self.data)
}


ThreadB c = new ThreadC(exchange);
run()
{
   String other = exchange.exchange(self.data)
}

ThreadC d = new ThreadD(exchange);
run()
{
   String other = exchange.exchange(self.data)
}

在上面的例子中，4个线程并发的调用exchange，会两两交互数据。可能是A/B,  C/D，也可能A/C, B/D，也可能是A/D,  B/C。



Exchange实现

从简单的角度来考虑，Exchange只需要一个互斥变量就够了。因为可以限制，任何时候，只能有1对发生交换，不是多对，同时发生交换。

但为了提高并发度，Exchange内部用了多个变量，在其内部，称之为Slot。



public class Exchanger {

    private static final class Slot extends AtomicReference

本文由职坐标整理并发布，希望对同学们有所帮助。了解更多详情请关注职坐标系统运维之Exchange频道！