Struct Task 

pub struct Task {
    pub id: TaskId,
    pub priority: Priority,
    pub estimated_cost: u32,
    /* private fields */
}

An internal representation of a unit of work.

This struct wraps the user’s closure in a type-erased Box<dyn FnOnce...>, allowing different kinds of functions to be stored and executed by workers.

Fields

id: TaskId

priority: Priority

estimated_cost: u32

Implementations

impl Task

pub fn new_for_cpu<F, Output>( priority: Priority, estimated_cost: u32, work_fn: F, result_tx: Sender<Result<Output, TaskError>>, ) -> Self

where F: FnOnce() -> Result<Output, TaskError> + Send + 'static, Output: Send + 'static,

Creates a new Task from a user-provided function.

This wraps the function in a new closure that handles panic catching and sending the result back over a channel.

pub fn run(self) -> TaskExecutionOutcome

Executes the wrapped user function.

This is called by the VibeNode worker thread.

Trait Implementations

impl Debug for Task

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

Formats the value using the given formatter.