mondayio 0.2.4

A thread per core runtime based on iouring.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::atomic::{AtomicUsize, Ordering::Relaxed};

// thread id begins from 16.
// 0 is default thread
// 1-15 are unused
static ID_GEN: AtomicUsize = AtomicUsize::new(16);

pub(crate) const DEFAULT_THREAD_ID: usize = 0;

/// Used to generate thread id.
pub(crate) fn gen_id() -> usize {
    ID_GEN.fetch_add(1, Relaxed)
}

pub(crate) fn get_current_thread_id() -> usize {
    crate::runtime::CURRENT.with(|ctx| ctx.thread_id)
}

pub(crate) fn try_get_current_thread_id() -> Option<usize> {
    crate::runtime::CURRENT.try_with(|maybe_ctx| maybe_ctx.map(|ctx| ctx.thread_id))
}