Класс Exchanger<V>

public class Exchanger<V> extends Object

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

Пример использования: Вот ключевые моменты класса, использующего 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() в другом потоке.