Package eu.svjatoslav.alyverkko_cli.commands.task_processor

Class TaskPriorityQueue

java.lang.Object

eu.svjatoslav.alyverkko_cli.commands.task_processor.TaskPriorityQueue

public class TaskPriorityQueue
extends Object

A custom priority queue implementation for TaskQueueEntry that maintains tasks in priority order. Uses a TreeSet for efficient insertion, polling, and iteration.

Constructor Summary

Constructors

Constructor	Description
TaskPriorityQueue()	Constructs a new empty task priority queue.

Method Summary

Modifier and Type	Method	Description
void	add(TaskProcessorCommand.TaskQueueEntry task)	Adds a task to the priority queue.
List<TaskProcessorCommand.TaskQueueEntry>	getAllTasks()	Returns all tasks in the queue in order of priority (highest priority first).
TaskProcessorCommand.TaskQueueEntry	poll()	Removes and returns the highest priority task from the queue.
void	removeIf(Predicate<TaskProcessorCommand.TaskQueueEntry> predicate)	Removes tasks matching the given predicate.

Methods inherited from class java.lang.Object

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

Constructor Details

TaskPriorityQueue

public TaskPriorityQueue()

Constructs a new empty task priority queue.

Method Details

add

public void add(TaskProcessorCommand.TaskQueueEntry task)

Adds a task to the priority queue.

Parameters:

task - the task to add (must not be null)

poll

public TaskProcessorCommand.TaskQueueEntry poll()

Removes and returns the highest priority task from the queue.

Returns:

the highest priority task, or null if the queue is empty

removeIf

public void removeIf(Predicate<TaskProcessorCommand.TaskQueueEntry> predicate)

Removes tasks matching the given predicate.

Parameters:

predicate - the condition for removal (must not be null)

getAllTasks

public List<TaskProcessorCommand.TaskQueueEntry> getAllTasks()

Returns all tasks in the queue in order of priority (highest priority first).

Returns:

a new list containing all tasks in priority order