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
/// NUMA-aware work-stealing scheduler with topology-aware task migration.
///
/// # Overview
///
/// This module provides a pure-Rust implementation of a NUMA-aware
/// work-stealing thread pool. Key components:
///
/// * [`types`] — data structures (`NumaTopology`, `Task`, `SchedulerStats`, …)
/// * [`topology`] — NUMA topology detection/queries (simulated, pure Rust)
/// * [`work_stealing`] — scheduler, per-worker deques, steal-victim selection
/// * [`migration`] — load-imbalance detection and migration planning
///
/// # Example
///
/// ```rust
/// use scirs2_core::numa_scheduler::{
/// types::{NumaTopology, WorkStealingConfig, Task},
/// topology::detect_topology,
/// work_stealing::NumaWorkStealingScheduler,
/// };
/// use std::sync::{Arc, atomic::{AtomicUsize, Ordering}};
///
/// let topo = detect_topology();
/// let config = WorkStealingConfig::default();
/// let sched = NumaWorkStealingScheduler::new(&config, topo);
///
/// let counter = Arc::new(AtomicUsize::new(0));
/// for _ in 0..10 {
/// let c = Arc::clone(&counter);
/// sched.submit(Task::new(move || { c.fetch_add(1, Ordering::Relaxed); }));
/// }
/// std::thread::sleep(std::time::Duration::from_millis(100));
/// sched.shutdown();
/// ```
// Convenience re-exports.
pub use ;
pub use ;
pub use ;
pub use ;