Класс 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() в другом потоке.