Method sharing_queue

src/thread_pool.rs:1050–1052

(&self)

        let resignations = self.resignations.fetch_sub(1, Ordering::Acquire);

        // If this was the last active freeze, wake up any threads that want to
        // resign.
        if resignations == 1 {
            let wants_to_resign = self.wants_to_resign.load(Ordering::Relaxed);
            for member_index in wants_to_resign.iter_bits() {
                self.get_member_data().semaphores[member_index].signal();