class Mosquito::ShuffleDequeueAdapter

Overview

The default dequeue adapter. Shuffles the queue list on each pass and returns the first available job.

The shuffle provides rough fairness across queues, preventing any single queue from being consistently checked first.

Defined in:

mosquito/dequeue_adapters/shuffle_dequeue_adapter.cr

Instance Method Summary

#dequeue(queue_list : Runners::QueueList) : Tuple(JobRun, Queue) | Nil
Attempt to dequeue a job from one of the queues managed by queue_list.

Instance methods inherited from class `Mosquito::DequeueAdapter`

Instance Method Detail

def dequeue(queue_list : Runners::QueueList) : Tuple(JobRun, Queue) | Nil #

Description copied from class Mosquito::DequeueAdapter

Attempt to dequeue a job from one of the queues managed by queue_list.

Returns a tuple of {JobRun, Queue} when a job is available, or nil when all queues are empty.