Struct Scheduler 

pub struct Scheduler<T> { /* private fields */ }

Multi-tenant in-process scheduler with DRR fairness and explicit backpressure.

Implementations

impl<T> Scheduler<T>

pub fn set_tenant_quantum(&self, tenant: TenantKey, quantum: u64)

Sets a static DRR quantum override for a tenant.

pub fn clear_tenant_quantum(&self, tenant: TenantKey)

Removes a static DRR quantum override for a tenant.

pub fn set_quantum_provider( &self, provider: Option<Arc<dyn Fn(TenantKey) -> u64 + Send + Sync>>, )

Sets or clears the dynamic per-tenant quantum provider.

pub fn new(config: SchedulerConfig) -> Scheduler<T>

Creates a scheduler with the provided configuration.

pub fn enqueue(&self, tenant: TenantKey, task: Task<T>) -> EnqueueResult

Enqueues a task without returning a cancel handle.

pub fn enqueue_with_handle( &self, tenant: TenantKey, task: Task<T>, ) -> EnqueueWithHandleResult

Enqueues a task and returns a TaskHandle that can be cancelled.

pub fn cancel(&self, handle: TaskHandle) -> CancelResult

Cancels a pending task identified by handle.

Cancellation is best-effort for pending work and does not affect tasks that have already been dequeued for execution.

pub fn try_dequeue(&self) -> DequeueResult<T>

Attempts to dequeue one task without blocking.

pub fn dequeue_blocking(&self) -> DequeueResult<T>

Dequeues one task, blocking until work is available or scheduler closes.

pub fn dequeue_blocking_timeout(&self, timeout: Duration) -> DequeueResult<T>

Dequeues one task, waiting at most timeout.

Returns DequeueResult::Empty on timeout when the scheduler is still open.

pub fn stats(&self) -> SchedulerStats

Returns a snapshot of current scheduler metrics.

pub fn close(&self)

Alias for Scheduler::close_immediate.

pub fn close_immediate(&self)

Closes immediately: stops accepting new work and wakes blocked consumers.

pub fn close_drain(&self)

Closes in drain mode: stops accepting and drains queued work before closing.

pub fn close_with_mode(&self, mode: CloseMode)

Closes using the provided mode.