moirai-core 0.4.0

Core abstractions and traits for the Moirai concurrency library
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

//! Platform abstraction layer for cross-platform compatibility.
//!
//! This module provides a unified interface for platform-specific functionality,
//! following the Dependency Inversion Principle (SOLID) and making the code more
//! composable (CUPID).

#![allow(unused_imports)]

// Re-export common types based on platform
#[cfg(feature = "std")]
pub use std::{
    boxed::Box,
    collections::HashMap,
    string::String,
    sync::Arc,
    time::{Duration, Instant},
    vec::Vec,
};

#[cfg(not(feature = "std"))]
pub use alloc::{boxed::Box, collections::HashMap, string::String, sync::Arc, vec::Vec};

#[cfg(not(feature = "std"))]
pub use core::time::Duration;

// Platform-specific atomic operations
#[cfg(feature = "std")]
pub use std::sync::atomic::{
    compiler_fence, fence, AtomicBool, AtomicPtr, AtomicU32, AtomicU64, AtomicUsize, Ordering,
};

#[cfg(not(feature = "std"))]
pub use core::sync::atomic::{
    compiler_fence, fence, AtomicBool, AtomicPtr, AtomicU32, AtomicU64, AtomicUsize, Ordering,
};

// Platform-specific cell types
#[cfg(feature = "std")]
pub use std::cell::{Cell, RefCell, UnsafeCell};

#[cfg(not(feature = "std"))]
pub use core::cell::{Cell, RefCell, UnsafeCell};

// Platform-specific memory operations
#[cfg(feature = "std")]
pub use std::mem::{self, align_of, forget, replace, size_of, swap, MaybeUninit};

#[cfg(not(feature = "std"))]
pub use core::mem::{self, align_of, forget, replace, size_of, swap, MaybeUninit};

// Platform-specific pointer operations
#[cfg(feature = "std")]
pub use std::ptr::{self, null, null_mut, NonNull};

#[cfg(not(feature = "std"))]
pub use core::ptr::{self, null, null_mut, NonNull};

// Platform-specific marker types
#[cfg(feature = "std")]
pub use std::marker::{PhantomData, Send, Sync};

#[cfg(not(feature = "std"))]
pub use core::marker::{PhantomData, Send, Sync};

// Platform-specific ops
#[cfg(feature = "std")]
pub use std::ops::{Deref, DerefMut, Drop, Fn, FnMut, FnOnce};

#[cfg(not(feature = "std"))]
pub use core::ops::{Deref, DerefMut, Drop, Fn, FnMut, FnOnce};

// Platform-specific formatting
#[cfg(feature = "std")]
pub use std::fmt::{self, Debug, Display};

#[cfg(not(feature = "std"))]
pub use core::fmt::{self, Debug, Display};

// Time abstraction for no-std environments
#[cfg(not(feature = "std"))]
#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord)]
pub struct Instant(u64);

#[cfg(not(feature = "std"))]
impl Instant {
    /// Create a new instant representing "now"
    pub fn now() -> Self {
        // In no-std, we can't get real time, so use a counter
        // Monotonic counter for simulating Instant::now() in no-std environments
        static COUNTER: AtomicU64 = AtomicU64::new(0);
        Instant(COUNTER.fetch_add(1, Ordering::Relaxed))
    }

    /// Get duration since another instant
    pub fn duration_since(&self, earlier: Instant) -> Duration {
        let nanos = self.0.saturating_sub(earlier.0);
        Duration::from_nanos(nanos)
    }

    /// Get elapsed time since this instant
    pub fn elapsed(&self) -> Duration {
        Instant::now().duration_since(*self)
    }
}

// Mutex abstraction
#[cfg(feature = "std")]
pub use std::sync::{Mutex, MutexGuard, RwLock, RwLockReadGuard, RwLockWriteGuard};

#[cfg(not(feature = "std"))]
pub use spin::{Mutex, MutexGuard, RwLock, RwLockReadGuard, RwLockWriteGuard};

/// Channel abstraction for cross-platform message passing.
///
/// This module provides a unified interface for channels that works
/// across different platforms and feature configurations.
pub mod channel {
    #[cfg(feature = "std")]
    pub use std::sync::mpsc::{channel, Receiver, RecvError, Sender, TryRecvError};

    #[cfg(not(feature = "std"))]
    pub use alloc::sync::mpsc::{channel, Receiver, RecvError, Sender, TryRecvError};
}

/// Thread abstraction for cross-platform threading support.
///
/// This module provides a unified interface for thread operations that works
/// across different platforms and feature configurations.
pub mod thread {
    #[cfg(feature = "std")]
    pub use std::thread::{sleep, spawn, yield_now, JoinHandle, Thread, ThreadId};

    #[cfg(not(feature = "std"))]
    compile_error!("Thread support requires std feature");
}