Класс Exchanger<V>

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

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

class FillAndEmpty {
   Exchanger<DataBuffer> exchanger = new Exchanger<DataBuffer>();
   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() в другом потоке.

Конструкторы

Exchanger

public Exchanger()

Создаёт новый Exchanger.

Методы

exchange

public V exchange(V x)
           throws InterruptedException

Параметры:

x - обмениваемый объект

Возвращает:

объект, предоставленный другим потоком

Исключения:

InterruptedException - если текущий поток был прерван во время ожидания

exchange

public V exchange(V x,
                  long timeout,
                  TimeUnit unit)
           throws InterruptedException,
                  TimeoutException

Параметры:

x - обмениваемый объект

timeout - максимальное время ожидания

unit - единица измерения времени для аргумента timeout

Возвращает:

объект, предоставленный другим потоком

Исключения:

InterruptedException - если текущий поток был прерван во время ожидания

TimeoutException - если заданное время ожидания истекло, прежде чем другой поток вошел в обмен