Struct AsyncScheduler 

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

Async wrapper around Scheduler.

Implementations

impl<T> AsyncScheduler<T>

pub fn new(inner: Arc<Scheduler<T>>) -> Self

Creates a new async wrapper over a shared core scheduler.

pub fn inner(&self) -> &Arc<Scheduler<T>>

Returns the shared core scheduler.

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

Enqueues a task.

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

Enqueues a task and returns a cancellation handle.

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

Non-blocking dequeue attempt.

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

Attempts to cancel pending work by handle.

pub fn stats(&self) -> SchedulerStats

Returns scheduler metric snapshot.

pub fn close(&self)

Alias for AsyncScheduler::close_immediate.

pub fn close_immediate(&self)

Closes immediately.

pub fn close_drain(&self)

Closes in drain mode.

pub fn close_with_mode(&self, mode: CloseMode)

Closes using a specific mode.

pub fn receiver(&self) -> AsyncReceiver<T>

Returns a receiver-style async dequeue helper.

pub fn stream(&self) -> AsyncStream<T>

Returns a Stream wrapper for dequeue operations.

impl<T: Send + 'static> AsyncScheduler<T>

pub async fn dequeue_async(&self) -> DequeueResult<T>

Performs blocking dequeue on a Tokio blocking thread.

pub fn receiver_with_worker(&self, buffer: usize) -> AsyncWorkerReceiver<T>

Returns a receiver powered by a dedicated dequeue worker thread.

pub fn stream_with_worker(&self, buffer: usize) -> AsyncWorkerReceiver<T>

Returns a stream powered by a dedicated dequeue worker thread.

Trait Implementations

impl<T> Clone for AsyncScheduler<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.