Struct LanePool 

pub struct LanePool { /* private fields */ }

Persistent worker threads for one lane-partitioned program.

Implementations

impl LanePool

pub const DEFAULT_IDLE_SPIN: Duration

Default time an idle worker keeps polling for the next kernel before it parks.

pub fn new(lanes: u32) -> Result<Self>

Start lanes - 1 worker threads; lane 0 runs on the dispatching thread.

pub fn with_idle_spin(lanes: u32, idle_spin: Duration) -> Result<Self>

pub fn lanes(&self) -> u32

pub fn run( &mut self, schedule: &LaneSchedule, runner: &dyn LaneTaskRunner, ) -> Result<(), LaneTaskFailure>

Execute one kernel and return its failure, preferring non-fatal errors to captured assertions before comparing task indices.

After a failure, tasks that have not started are skipped; every lane still finishes before this call returns.

Trait Implementations

impl Debug for LanePool

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

Formats the value using the given formatter.

impl Drop for LanePool

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.