Method map_current

src/thread_pool.rs:1174–1198

(f: F)

                // broadcasts.
                if (resignations >> 26) - 1 == 0 {
                    atomic_wait::wake_all(&*thread_pool.resignations);
                }
                // Exit the CAS loop.
                break;
            }
        }

        // Swap back to pointing to the previous value (possibly null).
        WORKER_PTR.with(|ptr| ptr.set(outer_ptr));

        // The worker is fully torn down, so panics may unwind freely again.
        core::mem::forget(abort_guard);

        // If the closure panicked, re-raise it now that teardown is complete so
        // that it propagates to the caller. Otherwise return its result.
        match result {
            Ok(result) => result,
            Err(panic) => unwind::resume_unwinding(panic),
        }
    }

    /// Returns a reference to the push-side `Sharer` queue for this
    /// worker's seat.
    #[inline(always)]
    fn sharing_queue(&self) -> &'static Sharer<JobRef> {
        &self.member_data.sharers[self.member_index]
    }