Struct ResourceMonitor 

pub struct ResourceMonitor { /* private fields */ }

Heuristic resource availability monitor.

Uses std::thread::available_parallelism to detect the logical CPU count and applies simple thresholds to calculate recommended parallelism.

This is a local resource monitor; it does not query remote cluster nodes. For cluster-level resource management see super::ClusterManager.

Example

use scirs2_core::distributed::primitives::ResourceMonitor;

let monitor = ResourceMonitor::new(0.8, 1_000_000_000);
let workers = monitor.available_workers();
assert!(workers >= 1);
let chunk = monitor.recommended_chunk_size(1_000_000);
assert!(chunk >= 64);
assert!(monitor.can_submit());

Implementations

impl ResourceMonitor

pub fn new(cpu_threshold: f64, memory_threshold: usize) -> Self

Create a new ResourceMonitor.

• cpu_threshold: fraction of CPUs (0.0–1.0) to allocate. Values outside [0, 1] are clamped.
• memory_threshold: maximum estimated memory usage (bytes) before can_submit would return false in a future implementation.

pub fn logical_cpu_count(&self) -> usize

Number of logical CPUs detected on this machine.

pub fn available_workers(&self) -> usize

Recommended number of worker threads.

Returns max(1, floor(cpu_threshold × logical_cpus)).

pub fn recommended_chunk_size(&self, total_work: usize) -> usize

Recommended chunk size for total_work items given the current worker count.

Targets 4 chunks per worker (good for work-stealing granularity) with a minimum of 64 items per chunk.

pub fn can_submit(&self) -> bool

Returns true when the system appears to have capacity headroom.

The current implementation always returns true because querying OS-level CPU and memory metrics portably and without unsafe code requires platform-specific system calls beyond scope here. The API is provided for future enhancement and testing.

pub fn cpu_threshold(&self) -> f64

CPU utilisation threshold (0.0–1.0).

pub fn memory_threshold(&self) -> usize

Memory threshold in bytes.

Trait Implementations

impl Clone for ResourceMonitor

fn clone(&self) -> ResourceMonitor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ResourceMonitor

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.