Struct WheelTimer

pub struct WheelTimer { /* private fields */ }

A reference-counted handle to a time wheel-based timer.

Examples

use wheeltimer::WheelTimer;

#[tokio::main]
async fn main() {
    let timer = WheelTimer::new(tokio::time::Duration::from_millis(100), 1024, 100000).unwrap();
    timer.start().await;
    let timeout = timer.new_timeout(tokio::time::Duration::from_secs(2),
        async move {
            // async task logic here
            println!("a delay task is executed");
        }
    ).await;

    tokio::time::sleep(tokio::time::Duration::from_secs(3)).await;
    timer.stop().await;
}

Implementations

impl WheelTimer

pub fn new( tick_duration: Duration, ticks_per_wheel: u32, max_pending_timeouts: u64, ) -> Result<Self, Error>

pub async fn start(&self)

pub async fn stop(&self)

pub async fn new_timeout<F>( &self, delay: Duration, task: F, ) -> Result<Timeout, Error>

where F: Future<Output = ()> + Send + 'static,

pub fn pending_timeouts(&self) -> u64

Trait Implementations

impl Clone for WheelTimer

fn clone(&self) -> WheelTimer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.