java.util.concurrent

Соедините интерфейсом с TransferQueue <E>

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

E - тип элементов сохранен в этом наборе

Все Суперинтерфейсы:

BlockingQueue <E>, Набор <E>, Повторяемый <E>, Очередь <E>

Все Известные Классы с реализацией:

LinkedTransferQueue

public interface TransferQueue<E>
extends BlockingQueue<E>

A BlockingQueue в котором производители могут ожидать потребителей, чтобы получить элементы. A TransferQueue может быть полезным например в приложениях передачи сообщений в который производители иногда (использующий метод transfer(E)) ждите получения элементов потребителями, вызывающими take или poll, в то время как в других случаях ставят в очередь элементы (через метод put) не ожидая получения. Неблокирование и версии тайм-аута tryTransfer также доступны. A TransferQueue май также быть запрошенным, через hasWaitingConsumer(), есть ли какие-либо потоки, ожидающие элементов, который является обратной аналогией с a peek работа.

Как другие очереди блокирования, a TransferQueue может быть ограниченная емкость. Если так, предпринятая работа передачи может первоначально блокировать ожидание свободного места, и/или впоследствии блокировать ожидание приема потребителем. Отметьте это в очереди с нулевой емкостью, такой как SynchronousQueue, put и transfer эффективно синонимичны.

Этот интерфейс является элементом Платформы Наборов Java.

С тех пор:

1.7

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

Методы

Модификатор и Тип	Метод и Описание
int	getWaitingConsumerCount() Возвращает оценку числа потребителей, ожидающего, чтобы получить элементы через BlockingQueue.take() или синхронизированный poll.
boolean	hasWaitingConsumer() Возвраты true если есть по крайней мере один потребитель, ожидающий, чтобы получить элемент через BlockingQueue.take() или синхронизированный poll.
void	transfer(E e) Передает элемент потребителю, ожидая в случае необходимости, чтобы сделать так.
boolean	tryTransfer(E e) Передает элемент ожидающему потребителю сразу, если возможный.
boolean	tryTransfer(E e, long timeout, TimeUnit unit) Передает элемент потребителю, если возможно сделать так прежде, чем тайм-аут протекает.

Методы, наследованные от интерфейса java.util.concurrent. BlockingQueue

add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take

Методы, наследованные от интерфейса java.util. Очередь

element, peek, poll, remove

Методы, наследованные от интерфейса java.util. Набор

addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, removeAll, retainAll, size, toArray, toArray

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

tryTransfer

boolean tryTransfer(E e)

Передает элемент ожидающему потребителю сразу, если возможный.

Более точно, сразу передает указанный элемент, если там существует потребитель, уже ожидающий, чтобы получить это (в BlockingQueue.take() или синхронизированный poll), иначе возврат false не ставя в очередь элемент.

Параметры:

e - элемент, чтобы передать

Возвраты:

true если элемент был передан, еще false

Броски:

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

NullPointerException - если указанный элемент является нулем

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

передача

void transfer(E e)
              throws InterruptedException

Передает элемент потребителю, ожидая в случае необходимости, чтобы сделать так.

Более точно, сразу передает указанный элемент, если там существует потребитель, уже ожидающий, чтобы получить это (в BlockingQueue.take() или синхронизированный poll), еще ожидает, пока элемент не получается потребителем.

Параметры:

e - элемент, чтобы передать

Броски:

InterruptedException - если прервано, ожидая, когда элемент не оставляют ставившим в очередь

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

NullPointerException - если указанный элемент является нулем

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

tryTransfer

boolean tryTransfer(E e,
                  long timeout,
                  TimeUnit unit)
                    throws InterruptedException

Передает элемент потребителю, если возможно сделать так прежде, чем тайм-аут протекает.

Более точно, сразу передает указанный элемент, если там существует потребитель, уже ожидающий, чтобы получить это (в BlockingQueue.take() или синхронизированный poll), еще ожидает, пока элемент не получается потребителем, возвращаясь false если указанное время ожидания протекает прежде, чем элемент может быть передан.

Параметры:

e - элемент, чтобы передать

timeout - сколько времени ожидать перед отказом в модулях unit

unit - a TimeUnit определение, как интерпретировать timeout параметр

Возвраты:

true в случае успеха, или false если указанное время ожидания протекает перед завершением, когда элемент не оставляют ставившим в очередь

Броски:

InterruptedException - если прервано, ожидая, когда элемент не оставляют ставившим в очередь

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

NullPointerException - если указанный элемент является нулем

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

hasWaitingConsumer

boolean hasWaitingConsumer()

Возвраты true если есть по крайней мере один потребитель, ожидающий, чтобы получить элемент через BlockingQueue.take() или синхронизированный poll. Возвращаемое значение представляет мгновенное положение дел.

Возвраты:

true если есть по крайней мере один ожидающий потребитель

getWaitingConsumerCount

int getWaitingConsumerCount()

Возвращает оценку числа потребителей, ожидающего, чтобы получить элементы через BlockingQueue.take() или синхронизированный poll. Возвращаемое значение является приближением мгновенного положения дел, которое может быть неточным, если потребители завершились или бросили ожидать. Значение может быть полезным для контроля и эвристики, но не для управления синхронизацией. Реализации этого метода, вероятно, будут заметно медленнее чем те для hasWaitingConsumer().

Возвраты:

число потребителей, ожидающее, чтобы получить элементы