Skip to main content

Crate wasm_par_mq

Crate wasm_par_mq 

Source

Macros§

par_fn
This macro is used to wrap a function that can be called inside a parallel map.
register_fn
Macro to register a function that processes individual items. The function will be applied to each element in a chunk.
sync_fn
This macro is used to wrap a sync function that can be called with execute_async, and will call collect_vec_sync.

Structs§

IntoIter
Iter
A parallel iterator that distributes work across web workers.
ParMap
A parallel map operation (lazy - doesn’t execute until collected)

Traits§

IntoParallelIterator
Extension trait to convert collections into parallel iterators
ParallelIterator
ParallelSlice
Extension trait that mirrors rayon’s par_iter() method on slices

Functions§

execute_async
init_pool_async
Initialize the parallel execution pool in async mode.
init_pool_sync
Initialize pool in sync mode.
init_pool_sync_from_worker
Initialize pool in sync mode, reusing the current worker as SyncExecutor.
is_pool_initialized
Check if the pool has been initialized
num_workers
Get the number of workers in the pool
register_coordinator
Register the coordinator service worker.
start_sync_executor
Entry point called from worker_helpers.js bootstrap when loaded as a sync executor worker.
start_worker
Entry point called from worker_helpers.js bootstrap when loaded as a compute worker. Sets up message handling for task execution.