threadfin 0.1.2

A thread pool for running multiple tasks on a configurable group of threads.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::{
    task::Waker,
    thread::{self, Thread},
};

use once_cell::sync::Lazy;

/// Creates a dummy waker that does nothing.
pub(crate) fn empty_waker() -> Waker {
    static WAKER: Lazy<Waker> = Lazy::new(|| waker_fn::waker_fn(move || {}));

    WAKER.clone()
}

/// Creates a waker that unparks the current thread.
pub(crate) fn current_thread_waker() -> Waker {
    thread_waker(thread::current())
}

/// Creates a waker that unparks a thread.
pub(crate) fn thread_waker(thread: Thread) -> Waker {
    waker_fn::waker_fn(move || thread.unpark())
}