Класс ConcurrentLinkedQueue<E>

public class ConcurrentLinkedQueue<E>
extends AbstractQueue<E>
implements Queue<E>, Serializable

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

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

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

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

Массовые операции, добавляющие, удаляющие или проверяющие несколько элементов, такие как addAll(java.util.Collection<? extends E>), removeIf(java.util.function.Predicate<? super E>) или forEach(java.util.function.Consumer<? super E>), не гарантируют атомарное выполнение. Например, обход forEach параллельно с операцией addAll может наблюдать только некоторые добавленные элементы.

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

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

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

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

ConcurrentLinkedQueue

public ConcurrentLinkedQueue()

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

ConcurrentLinkedQueue

public ConcurrentLinkedQueue(Collection<? extends E> c)

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

Параметры:

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

Исключения:

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