uexec 0.1.4

Simple work-stealing global and local executor
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

use crate::{state::State, threads::Threads};

use std::{sync::Arc, task::Wake};

/* Wake the executor after registering us in the list of tasks that need polling */
pub(crate) struct MyWaker {
    id: u64,
    threads: Threads,
    state: State,
}

impl MyWaker {
    pub(crate) fn new(id: u64, threads: Threads, state: State) -> Self {
        Self { id, threads, state }
    }
}

impl Wake for MyWaker {
    fn wake(self: Arc<Self>) {
        self.state.register_pollable(self.id);
        self.threads.unpark_random();
    }
}

/* Dummy waker */
pub(crate) struct DummyWaker;

impl Wake for DummyWaker {
    fn wake(self: Arc<Self>) {}
}