Crate adze_concurrency_caps_core 

Compatibility façade for concurrency cap primitives and contracts.

Examples

use adze_concurrency_caps_core::{ConcurrencyCaps, parse_positive_usize_or_default};

// Build caps from a custom lookup (no env mutation)
let caps = ConcurrencyCaps::from_lookup(|_| None);
assert_eq!(caps.rayon_threads, 4);   // default
assert_eq!(caps.tokio_worker_threads, 2); // default

// Parse helper returns default for invalid input
assert_eq!(parse_positive_usize_or_default(Some("0"), 8), 8);
assert_eq!(parse_positive_usize_or_default(Some("16"), 8), 16);

Structs

ConcurrencyCaps

Environment-based concurrency cap configuration and defaults. Snapshot of active concurrency cap values.

ParallelPartitionPlan

Bounded parallel map and partition planning utilities. Planning metadata for bounded parallel partitioning.

Constants

DEFAULT_RAYON_NUM_THREADS

Environment-based concurrency cap configuration and defaults. Default thread count used for Rayon when RAYON_NUM_THREADS is unset/invalid.

DEFAULT_TOKIO_WORKER_THREADS

Environment-based concurrency cap configuration and defaults. Default worker count used for Tokio when TOKIO_WORKER_THREADS is unset/invalid.

RAYON_NUM_THREADS_ENV

Environment-based concurrency cap configuration and defaults. Environment variable used for Rayon global thread-pool caps.

TOKIO_WORKER_THREADS_ENV

Environment-based concurrency cap configuration and defaults. Environment variable used for Tokio worker-thread caps.

Functions

bounded_parallel_map

Bounded parallel map and partition planning utilities. Run a bounded parallel map operation.

current_caps

Environment-based concurrency cap configuration and defaults. Return the current caps resolved from environment values.

init_concurrency_caps

One-time concurrency initialization helpers (rayon global pool, caps bootstrap). Initialize concurrency caps by reading the current process environment.

init_rayon_global_once

One-time concurrency initialization helpers (rayon global pool, caps bootstrap). Initialize Rayon global thread-pool once for the current process.

is_already_initialized_error

One-time concurrency initialization helpers (rayon global pool, caps bootstrap). Return whether the provided message represents a Rayon global-pool already-initialized error.

normalized_concurrency

Bounded parallel map and partition planning utilities. Normalize a requested concurrency value.

parse_positive_usize_or_default

Environment-based concurrency cap configuration and defaults. Parse an optional positive integer value, falling back to default.