Function join

src/thread_pool.rs:2406–2417

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 [`

(a: A, b: B)

        // Collect and return results or propagate panics.
        jobs.into_iter()
            .zip(error_flags)
            .map(|((_, job), error_flag)| {
                if error_flag {
                    // SAFETY: `error_flag` (from `wait`) is `true`, so the job
                    // completed with an error.
                    let error = unsafe { job.unwrap_error() };
                    unwind::resume_unwinding(error);
                } else {
                    // SAFETY: `error_flag` (from `wait`) is `false`, so the job
                    // completed with a value.
                    unsafe { job.unwrap_output() }
                }
            })
            .collect()