Класс Exchanger<V>

public class Exchanger<V> extends Object

Точка синхронизации, в которой потоки могут образовывать пары и обмениваться элементами внутри пар. При входе в метод exchange каждый поток предоставляет объект, сопоставляется с потоком-партнёром и при возврате получает объект партнёра. Exchanger можно рассматривать как двунаправленную форму SynchronousQueue. Exchanger может быть полезен в таких приложениях, как генетические алгоритмы и конвейерные схемы.

Пример использования: Ниже приведены основные фрагменты класса, который использует Exchanger для обмена буферами между потоками: поток, заполняющий буфер, получает свежий пустой буфер, когда он ему нужен, передавая заполненный буфер потоку, который его опустошает.

class FillAndEmpty {
  Exchanger<DataBuffer> exchanger = new Exchanger<>();
  DataBuffer initialEmptyBuffer = ...; // a made-up type
  DataBuffer initialFullBuffer = ...;

  class FillingLoop implements Runnable {
    public void run() {
      DataBuffer currentBuffer = initialEmptyBuffer;
      try {
        while (currentBuffer != null) {
          addToBuffer(currentBuffer);
          if (currentBuffer.isFull())
            currentBuffer = exchanger.exchange(currentBuffer);
        }
      } catch (InterruptedException ex) { ... handle ...}
    }
  }

  class EmptyingLoop implements Runnable {
    public void run() {
      DataBuffer currentBuffer = initialFullBuffer;
      try {
        while (currentBuffer != null) {
          takeFromBuffer(currentBuffer);
          if (currentBuffer.isEmpty())
            currentBuffer = exchanger.exchange(currentBuffer);
        }
      } catch (InterruptedException ex) { ... handle ...}
    }
  }

  void start() {
    new Thread(new FillingLoop()).start();
    new Thread(new EmptyingLoop()).start();
  }
}

Эффекты согласованности памяти: для каждой пары потоков, успешно обменивающихся объектами с помощью Exchanger, действия, выполненные до exchange() в каждом потоке, предшествуют действиям, выполненным после возврата из соответствующего exchange() в другом потоке.