trale 0.3.0

Trale is a minimalistic Rust async executor using io_uring for efficient, correct task execution.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use std::task::Waker;

use uring::{MultishotUringIo, OneshotUringIo, ReactorUring};

mod uring;

pub type ReactorIo = OneshotUringIo<Waker>;
pub type MultishotReactorIo = MultishotUringIo<Waker>;

pub(crate) struct Reactor {}

thread_local! {
    static REACTOR: ReactorUring<Waker> = ReactorUring::new();
}

impl Reactor {
    pub fn new_io() -> ReactorIo {
        REACTOR.with(|r| r.new_oneshot_io())
    }

    pub fn new_multishot_io() -> MultishotReactorIo {
        REACTOR.with(|r| r.new_multishot_io())
    }

    pub fn react() {
        REACTOR.with(|r| {
            for waker in r.react() {
                waker.wake();
            }
        })
    }
}