Method spawn

src/thread_pool.rs:494–518

(self, scheduler: S, worker: Option<&Worker>)

pub trait Scheduler<'w>: Send + Sync {
    /// Queues a job ref.
    ///
    /// This is passed the job ref that should be queued, and the outcome of
    /// `Worker::with_current` in the current context. The worker parameter does
    /// not have to be used, it is simply provided to avoid a lookup.
    fn schedule(&self, job_ref: JobRef, worker: Option<&'w Worker>);
}

impl<'w, F> Scheduler<'w> for F
where
    F: Fn(JobRef, Option<&'w Worker>) + Send + Sync,
{
    #[inline(always)]
    fn schedule(&self, job_ref: JobRef, worker: Option<&'w Worker>) {
        self(job_ref, worker);
    }
}

// -----------------------------------------------------------------------------
// Spawn Trait

pub use async_task::Task;

/// A trait for types that can be spawned onto a [`ThreadPool`].
///
/// This trait is sealed and cannot be implemented outside of forte.
///
/// It is implemented for:
///