Java ArrayBlockingQueue: продвинутое руководство по блокирующим очередям и потокобезопасным операциям

Java ArrayBlockingQueue

Изучите Java ArrayBlockingQueue — узнайте, как создавать, манипулировать и потокобезопасно использовать эту очередь фиксированного размера с чёткими примерами.

Класс ArrayBlockingQueue в Java Collections Framework предоставляет ограниченную, потокобезопасную очередь, основанную на массиве. Он реализует интерфейс BlockingQueue, позволяя производителям и потребителям координироваться через блокирующие операции.

---

Создание ArrayBlockingQueue

Импортируйте java.util.concurrent.ArrayBlockingQueue и создайте экземпляр с фиксированной ёмкостью:

ArrayBlockingQueue<Type> queue = new ArrayBlockingQueue<>(capacity);

Где Type — тип элементов, а capacity — максимальный размер.

• Пример — очередь строк размера 5:

  ArrayBlockingQueue<String> animals = new ArrayBlockingQueue<>(5);

• Пример — очередь целых чисел размера 5:

  ArrayBlockingQueue<Integer> ages = new ArrayBlockingQueue<>(5);

Примечание: Ёмкость обязательна; она определяет ограниченный размер очереди.

---

Основные методы ArrayBlockingQueue

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

Вставка элементов

• add(E e) — добавляет элемент; выбрасывает IllegalStateException, если полна.
• offer(E e) — добавляет элемент; возвращает false, если полна.

ArrayBlockingQueue<String> animals = new ArrayBlockingQueue<>(5);
animals.add("Dog");
animals.offer("Cat");
animals.offer("Horse");
System.out.println("ArrayBlockingQueue: " + animals);

Вывод: ArrayBlockingQueue: [Dog, Cat, Horse]

Доступ к элементам

• peek() — получает голову без удаления; возвращает null, если пуста.
• iterator() — предоставляет fail-fast итератор по очереди.

String head = animals.peek();
System.out.println("Head element: " + head);
Iterator<String> it = animals.iterator();
while (it.hasNext()) {
    System.out.print(it.next() + ", ");
}

Вывод: Head element: Dog за которым следует список элементов.

Удаление элементов

• remove() — удаляет и возвращает голову; выбрасывает NoSuchElementException, если пуста.
• poll() — удаляет и возвращает голову; возвращает null, если пуста.
• clear() — очищает очередь.

String removed1 = animals.remove();
String removed2 = animals.poll();
animals.clear();
System.out.println("Updated queue: " + animals);

Вывод: Updated queue: []

---

Блокирующие операции: put() и take()

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

put()

Вставляет элемент, ожидая, если очередь полна. Может выбросить InterruptedException.

try {
    animals.put("Dog");
    animals.put("Cat");
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}

take()

Удаляет и возвращает голову, ожидая, если очередь пуста. Может выбросить InterruptedException.

try {
    String element = animals.take();
    System.out.println("Removed: " + element);
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}

---

Дополнительные удобные методы

Метод	Описание
contains(Object o)	Возвращает true, если очередь содержит указанный элемент.
size()	Возвращает текущее количество элементов.
toArray()	Преобразует очередь в массив.
toString()	Строковое представление очереди.

---

Зачем использовать ArrayBlockingQueue?

Потому что он предлагает:

• Потокобезопасность: Встроенная синхронизация для параллельного доступа.
• Фиксированный размер: Предотвращает неконтролируемый рост памяти.
• Блокирующая семантика: Упрощает координацию производитель-потребитель.

Когда один поток производит медленнее, чем потребляет потребитель, потребитель автоматически блокируется, избегая занятого ожидания и обеспечивая эффективное использование CPU.