Struct smartpool::channel::ShortestDeadlineFirst

pub struct ShortestDeadlineFirst { /* fields omitted */ }

A priority channel where each task corresponds to a time::SteadyTime deadline, and the task with the earliest deadline will be executed first.

Methods

impl ShortestDeadlineFirst

pub fn new() -> Self

impl ShortestDeadlineFirst

pub fn exec_after(
    &self,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    delay: Duration
)

Submit a future, with the deadline equal to a certain duration after the present.

Trait Implementations

impl Channel for ShortestDeadlineFirst

fn assign_bits(
    &mut self,
    assigner: &mut BitAssigner
) -> Result<(), NotEnoughBits>

fn poll(&self) -> Option<RunningTask>

fn into_shared(self) -> Arc<RwLock<Self>> where
    Self: Sized, 

Wrap self in a reference counted read/write lock, which is still a channel, and can have shared ownership, allowing it to be used in a scheduler.

impl ExecParam for ShortestDeadlineFirst

type Param = SteadyTime

fn submit(&self, task: RunningTask, deadline: SteadyTime)

Submit a raw running task.

fn exec(
    &self,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    param: Self::Param
)

Execute a future on this channel.

fn exec_push<I: Send + 'static, E: Send + 'static>(
    &self,
    future: impl Future<Item = I, Error = E> + Send + 'static,
    param: Self::Param
) -> PushFutureRecv<I, E>

Execute a future on this channel, and push the result to a push future.