Struct TimerThread

pub struct TimerThread {
    join_handle: JoinHandle<()>,
    send_time_request: Sender<(Instant, Box<dyn FnOnce() + Send + 'static>)>,
}

Uses a single thread to serve multiple sleep requests.

Fields

join_handle: JoinHandle<()>

send_time_request: Sender<(Instant, Box<dyn FnOnce() + Send + 'static>)>

Implementations

impl TimerThread

pub fn new() -> Self

fn safe_call(f: impl FnOnce())

Call a function and catch all potential panics.

fn background_work(rx: Receiver<(Instant, Box<dyn FnOnce() + Send + 'static>)>)

pub fn notify_at(&self, time: Instant, f: impl FnOnce() + Send + 'static)

fn notify_waker(&self, time: Instant, waker: Arc<Mutex<Result<Waker, bool>>>)

Notify a waker when the time has occurred. Sets Err(true) for inside the Mutex after the time has elapsed, so there is no point to queue a waker there after that.

pub fn delay_future(&self, delay: Duration) -> impl Future<Output = ()>

pub fn notify_future(&self, time: Instant) -> impl Future<Output = ()>

Create a future that will become ready at the specified time.

pub fn get_global() -> &'static Self

Trait Implementations

impl Default for TimerThread

fn default() -> Self

Returns the “default value” for a type.