compact1, compact2, compact3

java.util.concurrent

Класс ConcurrentLinkedQueue <E>

java.lang. Объект

java.util. AbstractCollection<E>

java.util. AbstractQueue <E>

java.util.concurrent.ConcurrentLinkedQueue<E>

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

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

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

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

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

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

Эта реализация использует эффективный алгоритм "без ожидания", основанный на одном описанном в Простом, Быстро, и Практическом Неблокировании и Блокировании Параллельных Алгоритмов Очереди Мэджедом М. Майклом и Майклом Л. Скоттом.

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

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

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

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

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

С тех пор:

1.5

См. Также:

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

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

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

Конструктор и Описание
ConcurrentLinkedQueue() Создает a ConcurrentLinkedQueue это первоначально пусто.
ConcurrentLinkedQueue(Collection<? extends E> c) Создает a ConcurrentLinkedQueue первоначально содержа элементы данного набора, добавленного в порядке обхода iterator набора.

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

Модификатор и Тип	Метод и Описание
boolean	add(E e) Вставляет указанный элемент в хвосте этой очереди.
boolean	addAll(Collection<? extends E> c) Добавляет все элементы в указанном наборе до конца этой очереди, в порядке, что они возвращаются iterator указанного набора.
boolean	contains(Object o) Возвраты true если эта очередь содержит указанный элемент.
boolean	isEmpty() Возвраты true если эта очередь не содержит элементов.
Iterator<E>	iterator() Возвращает iterator по элементам в этой очереди в надлежащей последовательности.
boolean	offer(E e) Вставляет указанный элемент в хвосте этой очереди.
E	peek() Получает, но не удаляет, глава этой очереди, или возвращает null, если эта очередь пуста.
E	poll() Получает и удаляет главу этой очереди, или возвращает null, если эта очередь пуста.
boolean	remove(Object o) Удаляет единственный экземпляр указанного элемента от этой очереди, если это присутствует.
int	size() Возвращает число элементов в этой очереди.
Объект[]	toArray() Возвращает массив, содержащий все элементы в этой очереди, в надлежащей последовательности.
<T> T[]	toArray(T[] a) Возвращает массив, содержащий все элементы в этой очереди, в надлежащей последовательности; тип времени выполнения возвращенного массива является типом указанного массива.

Методы, наследованные от class java.util. AbstractQueue

clear, element, remove

Методы, наследованные от class java.util. AbstractCollection

containsAll, removeAll, retainAll, toString

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

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

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

element, remove

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

clear, containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, spliterator, stream

Методы, наследованные от интерфейса java.lang. Повторяемый

forEach

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

ConcurrentLinkedQueue

public ConcurrentLinkedQueue()

Создает a ConcurrentLinkedQueue это первоначально пусто.

ConcurrentLinkedQueue

public ConcurrentLinkedQueue(Collection<? extends E> c)

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

Параметры:

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

Броски:

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

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

добавить

public boolean add(E e)

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

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

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

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

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

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

add в class AbstractQueue<E>

Параметры:

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

Возвраты:

true (как определено Collection.add(E))

Броски:

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

предложение

public boolean offer(E e)

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

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

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

Параметры:

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

Возвраты:

true (как определено Queue.offer(E))

Броски:

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

опрос

public E poll()

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

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

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

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

Возвраты:

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

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

public E peek()

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

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

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

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

Возвраты:

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

isEmpty

public boolean isEmpty()

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

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

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

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

isEmpty в class AbstractCollection<E>

Возвраты:

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

размер

public int size()

Возвращает число элементов в этой очереди. Если эта очередь содержит больше чем Integer.MAX_VALUE элементы, возвраты Integer.MAX_VALUE.

Остерегайтесь этого, в отличие от этого в большинстве наборов, этот метод НЕ является постоянно-разовой работой. Из-за асинхронной природы этих очередей, определяя текущее число элементов требует O (n) обход. Дополнительно, если элементы добавляются или удаляются во время выполнения этого метода, возвращенный результат может быть неточным. Таким образом этот метод обычно не очень полезен в параллельных приложениях.

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

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

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

size в class AbstractCollection<E>

Возвраты:

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

содержит

public boolean contains(Object o)

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

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

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

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

contains в class AbstractCollection<E>

Параметры:

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

Возвраты:

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

удалить

public boolean remove(Object o)

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

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

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

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

remove в class AbstractCollection<E>

Параметры:

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

Возвраты:

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

addAll

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

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

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

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

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

addAll в class AbstractQueue<E>

Параметры:

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

Возвраты:

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

Броски:

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

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

См. Также:

AbstractQueue.add(Object)

toArray

public Object[] toArray()

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

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

Этот метод действует как мост между основанными на массиве и основанными на наборе API.

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

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

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

toArray в class AbstractCollection<E>

Возвраты:

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

toArray

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

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

Если эта очередь помещается в указанный массив с комнатой, чтобы сэкономить (то есть, у массива есть больше элементов чем эта очередь), элемент в массиве сразу после конца очереди устанавливается в null.

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

Предположить x очередь, которая, как известно, содержала только строки. Следующий код может использоваться, чтобы вывести очередь в недавно выделенный массив String:

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

Отметьте это toArray(new Object[0]) идентично в функции toArray().

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

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

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

toArray в class AbstractCollection<E>

Параметры:

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

Возвраты:

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

Броски:

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

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

iterator

public Iterator<E> iterator()

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

Возвращенный iterator "слабо непротиворечивый" iterator, который никогда не будет бросать ConcurrentModificationException, и гарантии, чтобы пересечь элементы, поскольку они существовали на конструкцию iterator, и может (но не гарантироваться), отражают любые модификации, последующие за конструкцией.

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

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

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

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

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

iterator в class AbstractCollection<E>

Возвраты:

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