Struct SchedulerConfig 

pub struct SchedulerConfig {
    pub steal_threshold: u32,
    pub share_threshold: u32,
    pub max_steal_batch: u32,
    pub steal_neighborhood: u32,
    pub enabled: bool,
    pub strategy: SchedulingStrategy,
}

Configuration for dynamic actor scheduling.

Fields

steal_threshold: u32

Queue depth below which the scheduler tries to steal work.

share_threshold: u32

Queue depth above which the scheduler offers work to neighbors.

max_steal_batch: u32

Maximum messages to steal in one operation.

steal_neighborhood: u32

Number of neighbor blocks to check for work stealing.

enabled: bool

Enable/disable dynamic scheduling (can be toggled at runtime).

strategy: SchedulingStrategy

Scheduling strategy.

Implementations

impl SchedulerConfig

pub fn static_scheduling() -> Self

Create a static (no scheduling) configuration.

This is the current default behavior: each thread block processes its own fixed work queue. No load balancing occurs.

pub fn work_stealing(steal_threshold: u32) -> Self

Create a work-stealing configuration with the given threshold.

When an actor’s queue depth falls below steal_threshold, its scheduler warp will attempt to steal messages from the busiest neighbor.

pub fn round_robin() -> Self

Create a round-robin configuration.

Messages are distributed from a global work queue to blocks in round-robin order, using a global atomic counter for index assignment.

pub fn priority(levels: u32) -> Self

Create a priority-based configuration with the given number of levels.

Messages are bucketed into priority sub-queues (0 = lowest, levels-1 = highest). The scheduler warp dequeues from the highest-priority non-empty sub-queue first.

pub fn with_steal_threshold(self, threshold: u32) -> Self

Set the steal threshold.

pub fn with_share_threshold(self, threshold: u32) -> Self

Set the share threshold.

pub fn with_max_steal_batch(self, batch: u32) -> Self

Set the maximum steal batch size.

pub fn with_steal_neighborhood(self, neighborhood: u32) -> Self

Set the number of neighbor blocks to check for work stealing.

pub fn with_enabled(self, enabled: bool) -> Self

Enable or disable the scheduler.

pub fn is_dynamic(&self) -> bool

Check if this configuration uses dynamic scheduling (anything other than Static).

Trait Implementations

impl Clone for SchedulerConfig

fn clone(&self) -> SchedulerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SchedulerConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SchedulerConfig

fn default() -> Self

Returns the “default value” for a type.