parallel

parallel

The std::core::parallel module is intended to expose data-parallel array operations backed by the Rayon thread pool.

Caution

The parallel module is declared in the stdlib source, but it has no native runtime bindings at HEAD — it is not registered in the native module registry. Importing the module compiles, but calling any function fails at compile time with module namespace 'parallel' is not typed. Missing module schema for export .... The signatures below describe the planned API. Until the native bindings ship, use the sequential array methods (arr.map, arr.filter, etc.) or the rolling-window helpers in std::core::utils::rolling.

Import

use std::core::parallel

Planned Functions

parallel::map(array: Array<_>, callback) -> Array<_>

Map a function over an array in parallel.

parallel::filter(array: Array<_>, callback) -> Array<_>

Filter an array with a predicate in parallel.

parallel::for_each(array: Array<_>, callback)

Apply callback to each element for side effects in parallel.

parallel::reduce(array: Array<_>, callback, initial) -> _

Reduce an array to a single value using callback(acc, elem) -> acc.

parallel::sort(array: Array<_>, comparator) -> Array<_>

Sort an array with a comparator (a, b) -> number; uses a parallel sort for large inputs (1024+ elements).

parallel::chunks(array: Array<_>, size: int) -> Array<Array<_>>

Split an array into chunks of size elements. The last chunk may be shorter if array.length is not divisible by size.

parallel::num_threads() -> int

Return the number of threads in the Rayon pool.

See Also

• std::core::utils::rolling — rolling-window aggregations on numeric arrays
• Async — async scope, join, and structured concurrency for I/O parallelism