kithara-platform 0.0.1-alpha5

Cross-platform primitives (sync, time, thread) for native and wasm32.
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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

use core::num::NonZeroUsize;
use std::sync::atomic::Ordering;

use crate::{common::thread_id::ACTIVE_NAMED_THREADS, loom::thread as backend};
pub use crate::{
    common::{thread_id::active_named_thread_count, time::Duration},
    loom::thread::JoinHandle,
};

pub type Thread = ::loom::thread::Thread;
pub type ThreadId = ::loom::thread::ThreadId;

fn counted<F, T>(f: F) -> impl FnOnce() -> T + Send + 'static
where
    F: FnOnce() -> T + Send + 'static,
    T: Send + 'static,
{
    ACTIVE_NAMED_THREADS.fetch_add(1, Ordering::Release);
    move || {
        let result = f();
        ACTIVE_NAMED_THREADS.fetch_sub(1, Ordering::Release);
        result
    }
}

#[derive(Default)]
pub(crate) enum GateBackend {
    #[default]
    Loom,
}

impl GateBackend {
    #[inline]
    pub(crate) fn park_timeout(&self, duration: Duration) {
        match self {
            Self::Loom => backend::park_timeout(duration),
        }
    }

    #[inline]
    pub(crate) fn unpark(&self, _thread_id: u64, thread: Option<&Thread>) {
        match self {
            Self::Loom => {
                if let Some(thread) = thread {
                    backend::unpark(thread);
                }
            }
        }
    }
}

#[inline]
pub(crate) fn gate_instant(backend: &GateBackend) -> crate::time::Instant {
    match backend {
        GateBackend::Loom => crate::time::Instant::now(),
    }
}

#[inline]
pub fn yield_now() {
    backend::yield_now();
}

#[inline]
#[must_use]
pub fn is_worker_thread() -> bool {
    backend::is_worker_thread()
}

#[inline]
#[must_use]
pub fn is_main_thread() -> bool {
    backend::is_main_thread()
}

#[inline]
pub fn assert_main_thread(label: &str) {
    backend::assert_main_thread(label);
}

#[inline]
pub fn assert_not_main_thread(label: &str) {
    backend::assert_not_main_thread(label);
}

#[inline]
#[must_use]
pub fn current() -> Thread {
    backend::current()
}

pub fn spawn<F, T>(f: F) -> JoinHandle<T>
where
    F: FnOnce() -> T + Send + 'static,
    T: Send + 'static,
{
    backend::spawn(f)
}

pub fn spawn_named<F, T, N: Into<String>>(name: N, f: F) -> JoinHandle<T>
where
    F: FnOnce() -> T + Send + 'static,
    T: Send + 'static,
{
    backend::spawn_named_uncounted(name, counted(f))
}

#[track_caller]
pub fn sleep(duration: Duration) {
    backend::sleep(duration);
}

#[track_caller]
pub fn paced_backoff(duration: Duration) {
    let _ = duration;
    backend::yield_now();
}

#[track_caller]
pub fn park() {
    backend::park();
}

#[track_caller]
pub fn park_timeout(duration: Duration) {
    backend::park_timeout(duration);
}

pub fn unpark(thread: &Thread) {
    backend::unpark(thread);
}

#[must_use]
pub fn current_thread_id() -> u64 {
    backend::current_thread_id()
}

#[must_use]
pub fn available_parallelism() -> Option<NonZeroUsize> {
    backend::available_parallelism()
}