Класс ConcurrentLinkedQueue<E>

Безопасная для потоков неограниченная очередь, основанная на связанных узлах. Эта очередь упорядочивает элементы по принципу FIFO (первым пришёл — первым вышел). Голова очереди — это элемент, который находился в очереди дольше всего. Хвост очереди — это элемент, который находился в очереди меньше всего времени. Новые элементы вставляются в конец очереди, а операции извлечения элементов из очереди получают элементы с начала очереди. Очередь является подходящим выбором, когда много потоков будут совместно использовать доступ к одной общей коллекции. Как и большинство других реализаций коллекций для многопоточных задач, этот класс не допускает использование null элементов.

Эта реализация использует эффективный алгоритм без блокировки, основанный на описанном в Simple, Fast, and Practical Non-Blocking and Blocking Concurrent Queue Algorithms Майклом М. Майклом и Майклом Л. Скоттом.

Итераторы слабо согласованы, возвращая элементы, отражающие состояние очереди в какой-то момент времени или после создания итератора. Они не выбрасывают исключение ConcurrentModificationException, и могут продолжать свою работу параллельно с другими операциями. Элементы, присутствующие в очереди со времени создания итератора, будут возвращены ровно один раз.

Обратите внимание, что, в отличие от большинства коллекций, метод size является НЕ операцией с постоянной сложностью. Из-за асинхронной природы этих очередей, определение текущего количества элементов требует обхода элементов, и поэтому может сообщать неточные результаты, если эта коллекция изменяется во время обхода. Кроме того, массовые операции addAll, removeAll, retainAll, containsAll, equals, и toArray не гарантируются, что будут выполнены атомарно. Например, итератор, работающий параллельно с операцией addAll, может увидеть только некоторые добавленные элементы.

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

Влияние согласованности памяти: как и в других коллекциях для многопоточных задач, действия в потоке до размещения объекта в ConcurrentLinkedQueue очереди предшествуют последующим действиям доступа или удаления этого элемента из ConcurrentLinkedQueue в другом потоке.

Этот класс является членом Java Collections Framework.

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

ConcurrentLinkedQueue

public ConcurrentLinkedQueue()

Создаёт ConcurrentLinkedQueue , которая изначально пуста.

ConcurrentLinkedQueue

public ConcurrentLinkedQueue(Collection<? extends E> c)

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

Параметры:

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

Исключения:

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

Методы

add

public boolean add(E e)

Вставляет указанный элемент в конец этой очереди. Поскольку очередь неограничена, этот метод никогда не выбросит IllegalStateException или не вернёт false.

Определено в:

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

Определено в:

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

Переопределено в:

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

Параметры:

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

Возвращает:

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

Исключения:

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

offer

public boolean offer(E e)

Вставляет указанный элемент в конец этой очереди. Поскольку очередь неограничена, этот метод никогда не вернёт false.

Определено в:

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

Параметры:

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

Возвращает:

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

Исключения:

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

poll

public E poll()

Описание скопировано из интерфейса: Queue

Извлекает и удаляет голову этой очереди или возвращает null , если эта очередь пуста.

Определено в:

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

Возвращает:

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

peek

public E peek()

Описание скопировано из интерфейса: Queue

Извлекает, но не удаляет, голову этой очереди или возвращает null , если эта очередь пуста.

Определено в:

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

Возвращает:

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

isEmpty

public boolean isEmpty()

Возвращает true , если эта очередь не содержит элементов.

Определено в:

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

Переопределено в:

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

Возвращает:

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

size

public int size()

Определено в:

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

Определено в:

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

Возвращает:

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

contains

public boolean contains(Object o)

Возвращает true , если эта очередь содержит указанный элемент. Более формально, возвращает true тогда и только тогда, когда эта очередь содержит по крайней мере один элемент e такой, что o.equals(e).

Определено в:

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

Переопределено в:

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

Параметры:

o - проверяемый на предмет наличия в этой очереди объект

Возвращает:

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

remove

public boolean remove(Object o)

Удаляет единственный экземпляр указанного элемента из этой очереди, если он присутствует. Более формально, удаляет элемент e такой, что o.equals(e), если эта очередь содержит один или несколько таких элементов. Возвращает true , если эта очередь содержала указанный элемент (или, что эквивалентно, если эта очередь изменилась в результате вызова).

Определено в:

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

Переопределено в:

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

Параметры:

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

Возвращает:

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

addAll

public boolean addAll(Collection<? extends E> c)

Добавляет все элементы из заданного набора в конец этой очереди в порядке, в котором они возвращаются итератором заданного набора. Попытки addAll очереди к самой себе приводят к IllegalArgumentException.

Определено в:

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

Переопределено в:

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

Параметры:

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

Возвращает:

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

Исключения:

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

IllegalArgumentException - если набор является этой очередью

См. также:

AbstractQueue.add(Object)

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

iterator

public Iterator<E> iterator()

Определено в:

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

Определено в:

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

Определено в:

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

Возвращает:

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

spliterator

public Spliterator<E> spliterator()

Определено в:

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

Определено в:

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

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

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

Возвращает:

разделитель Spliterator по элементам этой очереди

С:

1.8