Java for Beginner

Основные методы PriorityBlockingQueue и примеры использования

put(E e):

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

PriorityBlockingQueue<Integer> queue = new PriorityBlockingQueue<>();
queue.put(15); // Вставка элемента в очередь

offer(E e):

Вставляет элемент в очередь. Возвращает true, если элемент был успешно вставлен.

boolean success = queue.offer(25); // Вставка элемента, возвращает true

take():

Извлекает и удаляет элемент с наивысшим приоритетом из головы очереди. Блокируется, если очередь пуста.

Integer element = queue.take(); // Блокирующее извлечение элемента

poll(long timeout, TimeUnit unit):

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

Integer polledElement = queue.poll(1, TimeUnit.SECONDS); // Пытается извлечь элемент с тайм-аутом

peek():

Возвращает элемент с наивысшим приоритетом, но не удаляет его из очереди. Возвращает null, если очередь пуста.

Integer peekedElement = queue.peek(); // Просмотр элемента без его удаления

size():

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

int size = queue.size(); // Получение размера очереди

contains(Object o):

Проверяет, содержится ли указанный элемент в очереди.

boolean contains = queue.contains(15); // Проверка наличия элемента в очереди

remove(Object o):

Удаляет указанное значение из очереди, если оно присутствует.

boolean removed = queue.remove(25); // Удаление элемента из очереди

Пример использования PriorityBlockingQueue

Обработка задач с приоритетами:

PriorityBlockingQueue можно использовать для реализации планировщика задач, где задачи с высоким приоритетом обрабатываются первыми.

import java.util.concurrent.PriorityBlockingQueue;

class Task implements Comparable<Task> {
    private int priority;
    private String name;

    public Task(int priority, String name) {
        this.priority = priority;
        this.name = name;
    }

    @Override
    public int compareTo(Task other) {
        return Integer.compare(this.priority, other.priority);
    }

    @Override
    public String toString() {
        return "Task{name='" + name + "', priority=" + priority + '}';
    }
}

public class TaskScheduler {
    public static void main(String[] args) throws InterruptedException {
        PriorityBlockingQueue<Task> taskQueue = new PriorityBlockingQueue<>();

        taskQueue.put(new Task(3, "Low priority task"));
        taskQueue.put(new Task(1, "High priority task"));
        taskQueue.put(new Task(2, "Medium priority task"));

        while (!taskQueue.isEmpty()) {
            Task task = taskQueue.take();
            System.out.println("Processing " + task);
        }
    }
}

#Java #Training #Medium #PriorityBlockingQueue

219 viewsДен, 14:34