Struct PriorityConfig

Source

pub struct PriorityConfig { /* private fields */ }

Expand description

Configuration for priority-based queue strategies.

Implementations§

Source §

impl PriorityConfig

Source

pub fn new() -> Self

Create a new empty priority configuration.

Source

pub fn default_strategy(self, strategy: QueueStrategy) -> Self

Set the default queue strategy for all priorities not matched by other rules.

Source

pub fn exact(self, priority: isize, strategy: QueueStrategy) -> Self

Set the queue strategy for an exact priority value.

Source

pub fn greater_or_equal(self, threshold: isize, strategy: QueueStrategy) -> Self

Set the queue strategy for priorities greater than or equal to the threshold. This is a convenience method that creates a range [threshold, isize::MAX].

Source

pub fn greater_than(self, threshold: isize, strategy: QueueStrategy) -> Self

Set the queue strategy for priorities greater than the threshold (exclusive). This is a convenience method that creates a range [threshold + 1, isize::MAX].

Source

pub fn less_or_equal(self, threshold: isize, strategy: QueueStrategy) -> Self

Set the queue strategy for priorities less than or equal to the threshold. This is a convenience method that creates a range [isize::MIN, threshold].

Source

pub fn less_than(self, threshold: isize, strategy: QueueStrategy) -> Self

Set the queue strategy for priorities less than the threshold (exclusive). This is a convenience method that creates a range [isize::MIN, threshold - 1].

Source

pub fn range(self, min: isize, max: isize, strategy: QueueStrategy) -> Self

Set the queue strategy for priorities within a range [min, max] (inclusive).

Source

pub fn strategy_for_priority(&self, priority: isize) -> QueueStrategy

Returns the queue strategy that would be used for the given priority.

This method evaluates all configured rules to determine which queue strategy (FIFO or LIFO) would be applied to a waiter with the specified priority.

§Arguments

priority - The priority level to query

§Returns

The QueueStrategy that would be used for the given priority.

§Examples

use ranked_semaphore::{PriorityConfig, QueueStrategy};

let config = PriorityConfig::new()
    .default_strategy(QueueStrategy::Fifo)
    .exact(10, QueueStrategy::Lifo);

assert_eq!(config.strategy_for_priority(5), QueueStrategy::Fifo);
assert_eq!(config.strategy_for_priority(10), QueueStrategy::Lifo);