Класс LinkedTransferQueue<E>

LinkedTransferQueue

public LinkedTransferQueue()

LinkedTransferQueue

public LinkedTransferQueue(Collection<? extends E> c)

Параметры:

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

Исключения:

NullPointerException - если указанный набор или любой из его элементов равны null

toArray

public Object[] toArray()

Указано в:

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

Переопределяет:

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

Возвращает:

массив, содержащий все элементы этой очереди

toArray

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

 String[] y = x.toArray(new String[0]);

Указано в:

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

Переопределяет:

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

Параметры типа:

T - тип компонента массива, который должен содержать коллекцию

Параметры:

a - массив, в который должны помещаться элементы очереди, если он достаточно велик; в противном случае для этой цели выделяется новый массив того же типа выполнения

Возвращает:

массив, содержащий все элементы этой очереди

Исключения:

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

NullPointerException - если указанный массив равен null

spliterator

public Spliterator<E> spliterator()

Указано в:

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

Указано в:

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

Примечание реализации:

Spliterator реализует trySplit для обеспечения ограниченной параллельности.

Возвращает:

Spliterator над элементами в этой очереди

С:

1.8

put

public void put(E e)

Указано в:

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

Параметры:

e - элемент для добавления

Исключения:

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

offer

public boolean offer(E e, long timeout, TimeUnit unit)

Указано в:

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

Параметры:

e - элемент для добавления

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

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

Возвращает:

true (как указано в BlockingQueue.offer)

Исключения:

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

offer

public boolean offer(E e)

Указано в:

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

Указано в:

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

Параметры:

e - элемент для добавления

Возвращает:

true (как указано в Queue.offer(E))

Исключения:

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

add

public boolean add(E e)

Указано в:

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

Указано в:

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

Указано в:

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

Переопределяет:

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

Параметры:

e - элемент для добавления

Возвращает:

true (как указано в Collection.add(E))

Исключения:

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

tryTransfer

public boolean tryTransfer(E e)

Указано в:

tryTransfer в интерфейсе TransferQueue<E>

Параметры:

e - элемент для передачи

Возвращает:

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

Исключения:

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

transfer

public void transfer(E e) throws InterruptedException

Указано в:

transfer в интерфейсе TransferQueue<E>

Параметры:

e - элемент для передачи

Исключения:

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

InterruptedException - если прервано ожидание, в этом случае элемент не оставляется в очереди

tryTransfer

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

Specified by:

tryTransfer в интерфейсе TransferQueue<E>

Parameters:

e - элемент для переноса

timeout - время ожидания до отказа, в единицах unit

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

Returns:

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

Throws:

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

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

take

public E take() throws InterruptedException

Specified by:

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

Returns:

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

Throws:

InterruptedException - если произошел сбой ожидания

poll

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

Specified by:

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

Parameters:

timeout - время ожидания до отказа, в единицах unit

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

Returns:

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

Throws:

InterruptedException - если произошел сбой ожидания

poll

public E poll()

Specified by:

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

Returns:

голова этой очереди или null если эта очередь пуста

drainTo

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

Specified by:

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

Parameters:

c - набор для переноса элементов

Returns:

количество перенесенных элементов

Throws:

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

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

drainTo

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

Specified by:

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

Parameters:

c - набор для переноса элементов

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

Returns:

количество перенесенных элементов

Throws:

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

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

iterator

public Iterator<E> iterator()

Specified by:

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

Specified by:

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

Specified by:

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

Returns:

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

peek

public E peek()

Specified by:

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

Returns:

голова этой очереди или null если эта очередь пуста

isEmpty

public boolean isEmpty()

Specified by:

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

Overrides:

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

Returns:

true если эта очередь не содержит элементов

hasWaitingConsumer

public boolean hasWaitingConsumer()

Specified by:

hasWaitingConsumer в интерфейсе TransferQueue<E>

Returns:

true если есть хотя бы один ожидающий потребитель

size

public int size()

Specified by:

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

Returns:

количество элементов в этой очереди

getWaitingConsumerCount

public int getWaitingConsumerCount()

Specified by:

getWaitingConsumerCount в интерфейсе TransferQueue<E>

Returns:

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

удалить

public boolean remove(Object o)

Указано:

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

Указано:

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

Переопределяет:

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

Параметры:

o - элемент, подлежащий удалению из этой очереди, если он присутствует

Возвращает:

true если эта очередь изменилась в результате вызова

содержит

public boolean contains(Object o)

Указано:

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

Указано:

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

Переопределяет:

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

Параметры:

o - объект, подлежащий проверке на наличие в этой очереди

Возвращает:

true если эта очередь содержит указанный элемент

remainingCapacity

public int remainingCapacity()

Указано:

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

Возвращает:

Integer.MAX_VALUE (как указано в BlockingQueue.remainingCapacity())

removeIf

public boolean removeIf(Predicate<? super E> filter)

Указано:

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

Параметры:

filter - предикат, который возвращает true для элементов, подлежащих удалению

Возвращает:

true если какие-либо элементы были удалены

Выбрасывает:

NullPointerException - если указанный фильтр равен null

removeAll

public boolean removeAll(Collection<?> c)

Указано:

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

Переопределяет:

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

Параметры:

c - набор, содержащий элементы, которые необходимо удалить из этого набора

Возвращает:

true если этот набор изменился в результате вызова

Выбрасывает:

NullPointerException - если этот набор содержит один или несколько нулевых элементов, а указанный набор не поддерживает нулевые элементы (опционально), или если указанный набор равен null

См. также:

• AbstractCollection.remove(Object)
• AbstractCollection.contains(Object)

retainAll

public boolean retainAll(Collection<?> c)

Указано:

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

Переопределяет:

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

Параметры:

c - набор, содержащий элементы, которые необходимо сохранить в этом наборе

Возвращает:

true если этот набор изменился в результате вызова

Выбрасывает:

NullPointerException - если этот набор содержит один или несколько нулевых элементов, а указанный набор не допускает нулевых элементов (опционально), или если указанный набор равен null

См. также:

• AbstractCollection.remove(Object)
• AbstractCollection.contains(Object)

очистить

public void clear()

Указано:

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

Переопределяет:

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

forEach

public void forEach(Consumer<? super E> action)

Указано:

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

Параметры:

action - действие, которое должно выполняться для каждого элемента

Выбрасывает:

NullPointerException - если указанное действие равно null