Function join_deep

src/thread_pool.rs:2586–2610

()

    Worker::with_current(|worker| match worker {
        Some(worker) => worker.spawn_on(member_index, work),
        None => DEFAULT_POOL.spawn_on(member_index, work),
    })
}

/// Waits for a future to complete.
///
/// 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::block_on`] instead. If you don't have a worker, but know which
/// thread pool you want to use, [`ThreadPool::block_on`] is more appropriate.
pub fn block_on<F, T>(future: F) -> T
where
    F: Future<Output = T> + Send,
    T: Send,
{
    Worker::with_current(|worker| match worker {
        Some(worker) => worker.block_on(future),
        None => DEFAULT_POOL.block_on(future),
    })
}

/// Executes the two closures, possibly in parallel.