Function join_wide

src/thread_pool.rs:2613–2638

()

}

/// Executes the two closures, possibly in parallel.
///
/// When executed on a thread that is currently registered as a worker (i.e. the
/// closure inside [`Membership::activate`], [`ThreadPool::with_worker`], or
/// similar) this is able to look up that registration and find the worker and
/// thread-pool implicitly.
///
/// If not called within a thread pool, this uses the [`DEFAULT_POOL`].
///
/// If you have a reference to a [`Worker`], it's better to use [`Worker::join`]
/// instead. If you don't have a worker, but know which thread pool you want to
/// use, [`ThreadPool::join`] is more appropriate.
pub fn join<A, B, RA, RB>(a: A, b: B) -> (RA, RB)
where
    A: FnOnce(&Worker) -> RA + Send,
    B: FnOnce(&Worker) -> RB + Send,
    RA: Send,
    RB: Send,
{
    Worker::with_current(|worker| match worker {
        Some(worker) => worker.join(a, b),
        None => DEFAULT_POOL.join(a, b),
    })
}

/// Creates a new scope for spawning non-static work.
///
/// When executed on a thread that is currently registered as a worker (i.e. the
/// closure inside [`Membership::activate`], [`ThreadPool::with_worker`], or