Класс ArrayBlockingQueue<E>

public ArrayBlockingQueue(int capacity)

Создаёт ArrayBlockingQueue с заданной (фиксированной) ёмкостью и политикой доступа по умолчанию.

public ArrayBlockingQueue(int capacity, boolean fair)

Создаёт ArrayBlockingQueue с заданной (фиксированной) ёмкостью и указанной политикой доступа.

public ArrayBlockingQueue(int capacity, boolean fair, Collection<? extends E> c)

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

public boolean add(E e)

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

public boolean offer(E e)

Вставляет указанный элемент в конец этой очереди, если это возможно сделать немедленно без превышения ёмкости очереди, возвращает true при успехе и false , если эта очередь полная. Этот метод, как правило, предпочтительнее метода add(E), который может не вставить элемент только при возникновении исключения.

public void put(E e) throws InterruptedException

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

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

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

public E poll()

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

public E take() throws InterruptedException

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

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

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

public E peek()

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

public int size()

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

public int remainingCapacity()

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

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

public boolean remove(Object o)

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

Удаление внутренних элементов в очередях на основе циклических массивов является по своей сути медленной и разрушительной операцией, поэтому следует предпринимать только в исключительных случаях, в идеале только когда известно, что к очереди не имеет доступа других потоков.

public boolean contains(Object o)

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

public Object[] toArray()

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

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

Этот метод служит мостом между API на основе массивов и на основе коллекций.

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

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

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

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

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

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

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

public void clear()

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

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

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

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

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

public Iterator<E> iterator()

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

Возвращаемый итератор является слабо согласованным.

public Spliterator<E> spliterator()

Возвращает Spliterator по элементам в этой очереди.

Возвращаемый разделитель является слабо согласованным.

Разделитель Spliterator сообщает о Spliterator.CONCURRENT, Spliterator.ORDERED и Spliterator.NONNULL.

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

Выполняет заданное действие для каждого элемента Iterable до тех пор, пока все элементы не будут обработаны или действие не выбросит исключение. Действия выполняются в порядке итерации, если этот порядок указан. Исключение, выброшенное действием, передаётся вызывающей стороне.

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

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

Удаляет все элементы этой коллекции, удовлетворяющие заданному предикату. Ошибки или исключения времени выполнения, выброшенные во время итерации или предикатом, передаются вызывающей стороне.

public boolean removeAll(Collection<?> c)

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

public boolean retainAll(Collection<?> c)

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