karmaio 0.1.0

A modern, fast, share-nothing asynchronous runtime for Rust
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

use std::{cell::UnsafeCell, task::Waker};

use super::utils::UnsafeCellExt;

pub(crate) struct Trailer {
    pub(crate) waker: UnsafeCell<Option<Waker>>,
}

impl Trailer {
    pub(crate) fn set_waker(&self, waker: Option<Waker>) {
        unsafe {
            self.waker.with_mut(|ptr| {
                *ptr = waker;
            });
        }
    }

    pub(crate) fn will_wake(&self, waker: &Waker) -> bool {
        unsafe { self.waker.with(|ptr| (*ptr).as_ref().unwrap().will_wake(waker)) }
    }

    pub(crate) fn wake_join(&self) {
        self.waker.with(|ptr| match unsafe { &*ptr } {
            Some(waker) => waker.wake_by_ref(),
            None => panic!("waker missing"),
        });
    }
}