Struct VmTask 

pub struct VmTask<'p> { /* private fields */ }

Drives one VM task on the scheduler. err_sink (first writer wins) receives the task’s error if it fails.

Implementations

impl<'p> VmTask<'p>

pub fn new( vm: Vm<'p>, output: Rc<RefCell<Vec<String>>>, err_sink: Option<ErrSink>, ) -> Self

A cooperative task draining into the shared output sink.

pub fn work_stealing(vm: Vm<'p>, err_sink: Option<ErrSink>) -> Self

A work-stealing task: output buffers locally (reported via take_output), and a spawn forwards a SpawnDesc the worker rebuilds — never a boxed body (which is !Send and could not cross a worker boundary anyway).

Trait Implementations

impl<'p> Task<'p> for VmTask<'p>

fn take_output(&mut self) -> Vec<String>

Hand the work-stealing coordinator this slice’s buffered output so it can be flushed in pick order. A no-op for cooperative tasks (they drain into the shared sink directly).

fn poll(&mut self, ctx: &mut TaskCtx) -> TaskStep<'p>

Advance the task until its next scheduling point.

fn priority(&self) -> u8

Scheduling priority — higher runs first under [crate::SchedulePolicy::Priority]. Defaults to 0 (all tasks equal).