Function block_on

src/thread_pool.rs:2383–2392

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 be

(future: F)

            //   every `StackJob` and returned: unwinding is ruled out by the
            //   abort guard held until every latch is set, which turns a
            //   panic that would unwind this frame into an abort. (Jobs
            //   executed while waiting never allow panics to escape their
            //   execution -- see the panic convention on `JobRef` -- so only
            //   unexpected panics can trip the guard.) No `StackJob` is moved
            //   or dropped before then.
            let job_ref = unsafe { job.as_job_ref() };
            self.member_data.broadcasts[*member_index].push(job_ref);
            self.member_data.semaphores[*member_index].signal();
        }

        // Wait for each job to finish.
        let error_flags: Vec<_> = jobs
            .iter()