Класс Exchanger<V>

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