Класс Exchanger

public class Exchanger<V> extends Object

Точка синхронизации, в которой потоки могут объединяться и обмениваться элементами в парах. Каждый поток представляет некоторый объект при входе в метод exchange, подбирается с партнёрским потоком и получает объект партнёра при возврате. Обменник можно рассматривать как двунаправленную форму 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() в другом потоке.