Struct Executor 

pub struct Executor { /* private fields */ }

The main executor that runs async tasks and handles I/O events.

Implementations

impl Executor

pub fn new() -> Result<Self>

Creates a new executor with default ID generator.

Examples found in repository

examples/basic_spawn.rs (line 4)

fn main() {
    let mut executor = Executor::new().unwrap();
    executor.spawn(Task::new(async {
        println!("Hello from an async task!");
    }));
    executor.run();
}

examples/custom_id_timer.rs (line 6)

fn main() {
    let executor = Arc::new(Mutex::new(Executor::new().unwrap()));
    let timer_data = executor.lock().unwrap().timer_data();
    let start = std::time::Instant::now();

    {
        let mut exec = executor.lock().unwrap();
        exec.spawn(Task::new(async move {
            println!("Starting timer at {:?}", start.elapsed());
            std::io::Write::flush(&mut std::io::stdout()).unwrap();
            let timer = TimerFuture::new(Duration::from_millis(500), timer_data);
            timer.await;
            println!("Timer fired at {:?}", start.elapsed());
        }));
    }

    executor.lock().unwrap().run();
}

pub fn spawn(&mut self, task: Task)

Spawns a new task with an async future.

Examples found in repository

examples/basic_spawn.rs (lines 5-7)

fn main() {
    let mut executor = Executor::new().unwrap();
    executor.spawn(Task::new(async {
        println!("Hello from an async task!");
    }));
    executor.run();
}

examples/custom_id_timer.rs (lines 12-18)

fn main() {
    let executor = Arc::new(Mutex::new(Executor::new().unwrap()));
    let timer_data = executor.lock().unwrap().timer_data();
    let start = std::time::Instant::now();

    {
        let mut exec = executor.lock().unwrap();
        exec.spawn(Task::new(async move {
            println!("Starting timer at {:?}", start.elapsed());
            std::io::Write::flush(&mut std::io::stdout()).unwrap();
            let timer = TimerFuture::new(Duration::from_millis(500), timer_data);
            timer.await;
            println!("Timer fired at {:?}", start.elapsed());
        }));
    }

    executor.lock().unwrap().run();
}

pub fn register_timer(&mut self, deadline: Instant, waker: Waker)

Registers a timer to wake at the given deadline.

pub fn timer_data(&self) -> Arc<Mutex<TimerData>>

Gets the timer data for creating timers.

Examples found in repository

examples/custom_id_timer.rs (line 7)

fn main() {
    let executor = Arc::new(Mutex::new(Executor::new().unwrap()));
    let timer_data = executor.lock().unwrap().timer_data();
    let start = std::time::Instant::now();

    {
        let mut exec = executor.lock().unwrap();
        exec.spawn(Task::new(async move {
            println!("Starting timer at {:?}", start.elapsed());
            std::io::Write::flush(&mut std::io::stdout()).unwrap();
            let timer = TimerFuture::new(Duration::from_millis(500), timer_data);
            timer.await;
            println!("Timer fired at {:?}", start.elapsed());
        }));
    }

    executor.lock().unwrap().run();
}

pub fn run(&mut self)

Runs the executor event loop until all tasks complete.

Examples found in repository

examples/basic_spawn.rs (line 8)

fn main() {
    let mut executor = Executor::new().unwrap();
    executor.spawn(Task::new(async {
        println!("Hello from an async task!");
    }));
    executor.run();
}

examples/custom_id_timer.rs (line 21)

fn main() {
    let executor = Arc::new(Mutex::new(Executor::new().unwrap()));
    let timer_data = executor.lock().unwrap().timer_data();
    let start = std::time::Instant::now();

    {
        let mut exec = executor.lock().unwrap();
        exec.spawn(Task::new(async move {
            println!("Starting timer at {:?}", start.elapsed());
            std::io::Write::flush(&mut std::io::stdout()).unwrap();
            let timer = TimerFuture::new(Duration::from_millis(500), timer_data);
            timer.await;
            println!("Timer fired at {:?}", start.elapsed());
        }));
    }

    executor.lock().unwrap().run();
}

pub fn reactor(&mut self) -> &mut Reactor

Returns a mutable reference to the reactor for I/O operations.