Struct Closure 

pub struct Closure<F, R> { /* private fields */ }

A simple closure-based task implementation.

Implementations

impl<F, R> Closure<F, R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

pub fn new(func: F, context: TaskContext) -> Self

Create a new closure task.

pub fn then<G, S>(self, continuation: G) -> Chained<Self, G>

where G: FnOnce(R) -> S + Send + 'static, S: Send + 'static,

Chain another operation after this task.

pub fn map<G, S>(self, mapper: G) -> Mapped<Self, G>

where G: FnOnce(R) -> S + Send + 'static, S: Send + 'static,

Map the output of this task.

Trait Implementations

impl<F, R> Task for Closure<F, R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

type Output = R

The output type produced by this task.

fn execute(self) -> Self::Output

Execute this task to completion.

fn context(&self) -> &TaskContext

Get the task context for scheduling and debugging.

fn is_stealable(&self) -> bool

Check if this task can be stolen by another thread.

fn estimated_cost(&self) -> u32

Estimate the computational cost of this task (for load balancing).