Function rayon_core::broadcast::broadcast_in

source ยท
pub(crate) unsafe fn broadcast_in<OP, R>(
    op: OP,
    registry: &Arc<Registry>,
) -> Vec<R>
where OP: Fn(BroadcastContext<'_>) -> R + Sync, R: Send,
Expand description

Execute op on every thread in the pool. It will be executed on each thread when they have nothing else to do locally, before they try to steal work from other threads. This function will not return until all threads have completed the op.

Unsafe because registry must not yet have terminated.