Method yield_local

src/thread_pool.rs:1462–1472

(&self)

            // * If the closure is `!Send`, `JobRef::execute` only runs on this
            //   thread. The closure is `Send`, so this obligation is vacuous.
            let batch_job_ref = unsafe { batch_job.into_job_ref() };
            // Push the batch job into the steal queue so siblings can steal it.
            if let Err(job_ref) = self.sharing_queue().push(batch_job_ref) {
                // If the queue is full, that indicates that the pool is
                // probably under high-load and we should continue local-first
                // operation.
                //
                // This just adds the jobs back to the local queue.
                self.execute(job_ref, false);
            } else {
                shared_job = true;
            }
        }