java.util.concurrent

Теплообменник класса <V>

java.lang. Объект

java.util.concurrent. Теплообменник <V>

Введите Параметры:

V - Тип объектов, которыми можно обменяться

public class Exchanger<V>
extends Object

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

С тех пор:

1.5

Сводка конструктора

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

Конструктор и Описание
Exchanger() Создает новый Теплообменник.

Сводка метода

Методы

Модификатор и Тип	Метод и Описание
V	exchange(V x) Ожидает другого потока, чтобы достигнуть этой точки обмена (если текущий поток не прерывается), и затем передает данный объект этому, получая его объект взамен.
V	exchange(V x, long timeout, TimeUnit unit) Ожидает другого потока, чтобы достигнуть этой точки обмена (если текущий поток не прерывается, или указанное время ожидания протекает), и затем передает данный объект этому, получая его объект взамен.

Методы java.lang унаследованный от класса. Объект

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Деталь конструктора

Теплообменник

public Exchanger()

Создает новый Теплообменник.

Деталь метода

обмен

public V exchange(V x)
           throws InterruptedException

Ожидает другого потока, чтобы достигнуть этой точки обмена (если текущий поток не прерывается), и затем передает данный объект этому, получая его объект взамен.

Если другой поток уже ожидает в точке обмена тогда, это возобновляется в целях планирования потоков и получает объект, который передает в текущий поток. Текущий поток сразу возвращается, получая объект, который передает к обмену тот другой поток.

Если никакой другой поток уже не ожидает при обмене тогда, текущий поток отключается в целях планирования потоков и бездействует, пока одна из двух вещей не происходит:

• Некоторый другой поток вводит обмен; или
• Некоторый другой поток прерывает текущий поток.

Если текущий поток:

• установили его прерванное состояние на записи в этот метод; или
• прерывается, ожидая обмена,

тогда InterruptedException бросается и прерванное состояние текущего потока очищается.

Параметры:

x - объект обмениваться

Возвраты:

объект обеспечил другим потоком

Броски:

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

обмен

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

Ожидает другого потока, чтобы достигнуть этой точки обмена (если текущий поток не прерывается, или указанное время ожидания протекает), и затем передает данный объект этому, получая его объект взамен.

Если другой поток уже ожидает в точке обмена тогда, это возобновляется в целях планирования потоков и получает объект, который передает в текущий поток. Текущий поток сразу возвращается, получая объект, который передает к обмену тот другой поток.

Если никакой другой поток уже не ожидает при обмене тогда, текущий поток отключается в целях планирования потоков и бездействует, пока одна из трех вещей не происходит:

• Некоторый другой поток вводит обмен; или
• Некоторый другой поток прерывает текущий поток; или
• Указанное время ожидания протекает.

Если текущий поток:

• установили его прерванное состояние на записи в этот метод; или
• прерывается, ожидая обмена,

тогда InterruptedException бросается и прерванное состояние текущего потока очищается.

Если указанное время ожидания протекает тогда TimeoutException бросается. Если время будет меньше чем или равно нулю, то метод не будет ожидать вообще.

Параметры:

x - объект обмениваться

timeout - максимальное время, чтобы ожидать

unit - единица измерения времени параметра timeout

Возвраты:

объект обеспечил другим потоком

Броски:

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

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