Package index

Channels

mizu_channel()

Create a Channel and Spawn Its Peer

mizu_send() mizu_recv()

Send and Receive over a Channel

mizu_send_batch() mizu_recv_batch()

Batched Send and Receive

mizu_close()

Close a Channel

mizu_alive()

Probe Peer Liveness

Pools

mizu_pool()

Create a Task Pool and Spawn Its Workers

mizu_pool_attach()

Attach to a Pool as a Submitter

mizu_submit() mizu_collect()

Submit a Task and Collect Its Result

mizu_submit_batch()

Submit a Batch of Tasks

mizu_collect_any()

Collect the First Available Result From Several Tasks

mizu_collect_all()

Collect the Results of Several Tasks, in Order

mizu_cancel()

Cancel a Task

mizu_current_pool()

The Evaluating Worker's Own Pool Handle

mizu_default_pool() mizu_set_default_pool() mizu_with_pool() mizu_local_pool()

The Process-Wide Default Pool

mizu_spawn_workers() mizu_retire_worker()

Grow or Shrink the Worker Set of a Pool

mizu_pool_stop()

Stop a Pool

Parallel map

mizu_map()

Parallel Map Over a Pool

mizu_map_prepare() mizu_map_run()

Prepared Maps: Stage Once, Run Many

Monitoring and debugging

mizu_pool_status()

Inspect a Pool

mizu_pool_stats()

Cumulative Pool Counters

mizu_pool_dump()

Dump the Distributed State of a Pool

mizu_pool_trace()

Trace Task Lifecycle Events

Cross-language interop

mizu_call() mizu_submit_call()

Call a Function in Another Language: the Task Specification

mizu_launcher()

Default Child Process Launcher

mizu_py_launcher()

Python Channel Peer Launcher

mizu_py_pool_launcher()

Python Pool Worker Launcher

Conditions and sentinels

mizu_error mizu_error_submit_timeout mizu_error_slots_exhausted mizu_error_stopped mizu_error_cancelled mizu_error_worker_died mizu_error_startup mizu_error_shm mizu_error_python_payload mizu_error_remote

Error Conditions

mizu_is_remote_error() mizu_raise()

Remote Errors

mizu_is_sentinel()

Test for a mizu Sentinel

Utilities

mizu_prune()

Remove Orphaned Shared Memory Regions

print(<mizu_channel>) print(<mizu_pool>) print(<mizu_task>) print(<mizu_map_prepared>) print(<mizu_sentinel>) print(<mizu_error_remote>)

Print Methods for mizu Objects