java.util.concurrent

Класс SynchronousQueue <E>

java.lang. Объект

java.util. AbstractCollection<E>

java.util. AbstractQueue <E>

java.util.concurrent. SynchronousQueue <E>

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

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

Все Реализованные Интерфейсы:

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

public class SynchronousQueue<E>
extends AbstractQueue<E>
implements BlockingQueue<E>, Serializable

Очередь блокирования, в которую каждый вставляет работу, должна ожидать соответствия, удаляют работу другим потоком, и наоборот. У синхронной очереди нет никакой внутренней емкости, не даже емкости одного. Вы не можете peek в синхронной очереди, потому что элемент только присутствует, когда Вы пытаетесь удалить это; невозможно вставить элемент (использующий любой метод), если другой поток не пытается удалить его; невозможно выполнить итерации, поскольку нет ничего, чтобы выполнить итерации. Глава очереди является элементом, который первая вставка с очередями потока пытается добавить к очереди; если нет такого потока с очередями тогда, никакой элемент не доступен для удаления, и poll() возвратит null. В целях других методов Collection (например contains), SynchronousQueue действует как пустой набор. Эта очередь не разрешает элементы null.

Синхронные очереди подобны каналам рандеву, используемым в CSP и Аде. Они хорошо подходят для проектов handoff, в которых объект, работающий в одном потоке, должен синхронизировать с объектом, работающим в другом потоке, чтобы вручить этому некоторую информацию, событие, или задачу.

Этот класс поддерживает дополнительную политику справедливости для того, чтобы упорядочить ожидающие потоки производителя и потребителя. По умолчанию это упорядочивание не гарантируется. Однако, очередь, созданная с набором справедливости к true, предоставляет доступ потоков в порядке FIFO.

Этот класс и его iterator реализуют все дополнительные методы Collection и Iterator интерфейсы.

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

С тех пор:

1.5

См. Также:

Сериализированная Форма

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

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

Конструктор и Описание
SynchronousQueue() Создает SynchronousQueue с несправедливой политикой доступа.
SynchronousQueue(boolean fair) Создает SynchronousQueue с указанной политикой справедливости.

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

Методы

Модификатор и Тип	Метод и Описание
void	clear() Ничего не делает.
boolean	contains(Object o) Всегда возвраты false.
boolean	containsAll(Collection<?> c) false возвратов, если данный набор не пуст.
int	drainTo(Collection<? super E> c) Удаляет все доступные элементы из этой очереди и добавляет их к данному набору.
int	drainTo(Collection<? super E> c, int maxElements) Удаляет самое большее данное число доступных элементов от этой очереди и добавляет их к данному набору.
boolean	isEmpty() Всегда возвраты true.
Iterator<E>	iterator() Возвращает пустой iterator, в котором hasNext всегда возвращает false.
boolean	offer(E e) Вставляет указанный элемент в эту очередь, если другой поток ожидает, чтобы получить это.
boolean	offer(E o, long timeout, TimeUnit unit) Вставляет указанный элемент в эту очередь, ожидая в случае необходимости до указанного времени ожидания для другого потока, чтобы получить это.
E	peek() Всегда возвраты null.
E	poll() Получает и удаляет главу этой очереди, если другой поток в настоящий момент делает элемент доступным.
E	poll(long timeout, TimeUnit unit) Получает и удаляет главу этой очереди, ожидая в случае необходимости до указанного времени ожидания, для другого потока, чтобы вставить это.
void	put(E o) Добавляет указанный элемент к этой очереди, ожидая в случае необходимости другого потока, чтобы получить это.
int	remainingCapacity() Всегда нуль возвратов.
boolean	remove(Object o) Всегда возвраты false.
boolean	removeAll(Collection<?> c) Всегда возвраты false.
boolean	retainAll(Collection<?> c) Всегда возвраты false.
int	size() Всегда нуль возвратов.
E	take() Получает и удаляет главу этой очереди, ожидая в случае необходимости другого потока, чтобы вставить это.
Объект[]	toArray() Возвращает массив нулевой длиной.
<T> T[]	toArray(T[] a) Устанавливает zeroeth элемент указанного массива к null (если у массива есть ненулевая длина), и возвращает это.

Методы java.util унаследованный от класса. AbstractQueue

add, addAll, element, remove

Методы java.util унаследованный от класса. AbstractCollection

toString

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

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

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

добавить

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

element, remove

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

addAll, equals, hashCode

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

SynchronousQueue

public SynchronousQueue()

Создает SynchronousQueue с несправедливой политикой доступа.

SynchronousQueue

public SynchronousQueue(boolean fair)

Создает SynchronousQueue с указанной политикой справедливости.

Параметры:

fair - если это правда, потоки ожидания спорят в порядке FIFO на доступ; иначе порядок является неуказанным.

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

поместить

public void put(E o)
         throws InterruptedException

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

Определенный:

put в интерфейсе BlockingQueue<E>

Параметры:

o - элемент, чтобы добавить

Броски:

InterruptedException - если прервано, ожидая

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

предложение

public boolean offer(E o,
            long timeout,
            TimeUnit unit)
              throws InterruptedException

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

Определенный:

offer в интерфейсе BlockingQueue<E>

Параметры:

o - элемент, чтобы добавить

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

unit - TimeUnit, определяющий, как интерпретировать параметр timeout

Возвраты:

true в случае успеха, или false, если указанное время ожидания протекает перед потребителем, появляется.

Броски:

InterruptedException - если прервано, ожидая

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

предложение

public boolean offer(E e)

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

Определенный:

offer в интерфейсе BlockingQueue<E>

Определенный:

offer в интерфейсе Queue<E>

Параметры:

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

Возвраты:

true, если элемент был добавлен к этой очереди, еще false

Броски:

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

взять

public E take()
       throws InterruptedException

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

Определенный:

take в интерфейсе BlockingQueue<E>

Возвраты:

глава этой очереди

Броски:

InterruptedException - если прервано, ожидая

опрос

public E poll(long timeout,
     TimeUnit unit)
       throws InterruptedException

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

Определенный:

poll в интерфейсе BlockingQueue<E>

Параметры:

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

unit - TimeUnit, определяющий, как интерпретировать параметр timeout

Возвраты:

глава этой очереди, или null, если указанное время ожидания протекает перед элементом, присутствуют.

Броски:

InterruptedException - если прервано, ожидая

опрос

public E poll()

Получает и удаляет главу этой очереди, если другой поток в настоящий момент делает элемент доступным.

Определенный:

poll в интерфейсе Queue<E>

Возвраты:

глава этой очереди, или null, если никакой элемент не доступен.

isEmpty

public boolean isEmpty()

Всегда возвраты true. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

isEmpty в интерфейсе Collection<E>

Переопределения:

isEmpty в классе AbstractCollection<E>

Возвраты:

true

размер

public int size()

Всегда нуль возвратов. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

size в интерфейсе Collection<E>

Определенный:

size в классе AbstractCollection<E>

Возвраты:

нуль.

remainingCapacity

public int remainingCapacity()

Всегда нуль возвратов. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

remainingCapacity в интерфейсе BlockingQueue<E>

Возвраты:

нуль.

очистить

public void clear()

Ничего не делает. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

clear в интерфейсе Collection<E>

Переопределения:

clear в классе AbstractQueue<E>

содержит

public boolean contains(Object o)

Всегда возвраты false. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

contains в интерфейсе Collection<E>

Определенный:

contains в интерфейсе BlockingQueue<E>

Переопределения:

contains в классе AbstractCollection<E>

Параметры:

o - элемент

Возвраты:

false

удалить

public boolean remove(Object o)

Всегда возвраты false. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

remove в интерфейсе Collection<E>

Определенный:

remove в интерфейсе BlockingQueue<E>

Переопределения:

remove в классе AbstractCollection<E>

Параметры:

o - элемент, чтобы удалить

Возвраты:

false

containsAll

public boolean containsAll(Collection<?> c)

false возвратов, если данный набор не пуст. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

containsAll в интерфейсе Collection<E>

Переопределения:

containsAll в классе AbstractCollection<E>

Параметры:

c - набор

Возвраты:

false, если данный набор не пусто

См. Также:

AbstractCollection.contains(Object)

removeAll

public boolean removeAll(Collection<?> c)

Всегда возвраты false. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

removeAll в интерфейсе Collection<E>

Переопределения:

removeAll в классе AbstractCollection<E>

Параметры:

c - набор

Возвраты:

false

См. Также:

AbstractCollection.remove(Object), AbstractCollection.contains(Object)

retainAll

public boolean retainAll(Collection<?> c)

Всегда возвраты false. У SynchronousQueue нет никакой внутренней емкости.

Определенный:

retainAll в интерфейсе Collection<E>

Переопределения:

retainAll в классе AbstractCollection<E>

Параметры:

c - набор

Возвраты:

false

См. Также:

AbstractCollection.remove(Object), AbstractCollection.contains(Object)

быстрый взгляд

public E peek()

Всегда возвраты null. SynchronousQueue не возвращает элементы, если активно не ожидал на.

Определенный:

peek в интерфейсе Queue<E>

Возвраты:

null

iterator

public Iterator<E> iterator()

Возвращает пустой iterator, в котором hasNext всегда возвращает false.

Определенный:

iterator в интерфейсе Iterable<E>

Определенный:

iterator в интерфейсе Collection<E>

Определенный:

iterator в классе AbstractCollection<E>

Возвраты:

пустой iterator

toArray

public Object[] toArray()

Возвращает массив нулевой длиной.

Определенный:

toArray в интерфейсе Collection<E>

Переопределения:

toArray в классе AbstractCollection<E>

Возвраты:

массив нулевой длиной

toArray

public <T> T[] toArray(T[] a)

Устанавливает zeroeth элемент указанного массива к null (если у массива есть ненулевая длина), и возвращает это.

Определенный:

toArray в интерфейсе Collection<E>

Переопределения:

toArray в классе AbstractCollection<E>

Параметры:

a - массив

Возвраты:

указанный массив

Броски:

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

drainTo

public int drainTo(Collection<? super E> c)

Описание скопировало с интерфейса: BlockingQueue

Удаляет все доступные элементы из этой очереди и добавляет их к данному набору. Эта работа может быть более эффективной чем повторный опрос этой очереди. Отказ встречался, пытаясь добавить элементы к набору, c может привести к элементам, находящимся ни в одном, или или оба набора, когда связанное исключение выдается. Попытки истощить очередь, чтобы самостоятельно привести к IllegalArgumentException. Далее, поведение этой работы неопределено, если указанный набор изменяется, в то время как работа происходит.

Определенный:

drainTo в интерфейсе BlockingQueue<E>

Параметры:

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

Возвраты:

число элементов передается

Броски:

UnsupportedOperationException - если добавление элементов не поддерживается указанным набором

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

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

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

drainTo

public int drainTo(Collection<? super E> c,
          int maxElements)

Описание скопировало с интерфейса: BlockingQueue

Удаляет самое большее данное число доступных элементов от этой очереди и добавляет их к данному набору. Отказ встречался, пытаясь добавить элементы к набору, c может привести к элементам, находящимся ни в одном, или или оба набора, когда связанное исключение выдается. Попытки истощить очередь, чтобы самостоятельно привести к IllegalArgumentException. Далее, поведение этой работы неопределено, если указанный набор изменяется, в то время как работа происходит.

Определенный:

drainTo в интерфейсе BlockingQueue<E>

Параметры:

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

maxElements - максимальное количество элементов, чтобы передать

Возвраты:

число элементов передается

Броски:

UnsupportedOperationException - если добавление элементов не поддерживается указанным набором

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

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

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