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

use std::{
    hash::{DefaultHasher, Hash, Hasher},
    sync::atomic::{AtomicUsize, Ordering},
};

/// Number of active threads spawned via the platform `spawn_named`.
///
/// Incremented on spawn, decremented when the thread function returns.
/// Used by thread-budget tests to count only kithara-owned threads.
pub(crate) static ACTIVE_NAMED_THREADS: AtomicUsize = AtomicUsize::new(0);

/// Returns the number of currently active threads spawned via the platform
/// `spawn_named`.
#[must_use]
pub fn active_named_thread_count() -> usize {
    ACTIVE_NAMED_THREADS.load(Ordering::Acquire)
}

/// Stable `u64` hash of a thread id. Used both for shard indexing and (under
/// `flash`) as the engine's thread key: `current_thread_id` and the flash
/// `unpark`'s target derive from the SAME hasher so a park and its wake agree.
/// Generic over the backend's `ThreadId` type (std vs `wasm_safe_thread`).
#[inline]
#[must_use]
pub(crate) fn thread_id_hash<I: Hash>(id: I) -> u64 {
    let mut hasher = DefaultHasher::new();
    id.hash(&mut hasher);
    hasher.finish()
}