Struct rayon_core::job::StackJob

pub(crate) struct StackJob<L, F, R>
where
    L: Latch + Sync,
    F: FnOnce(bool) -> R + Send,
    R: Send,
{
    pub(crate) latch: L,
    func: UnsafeCell<Option<F>>,
    result: UnsafeCell<JobResult<R>>,
}

A job that will be owned by a stack slot. This means that when it executes it need not free any heap data, the cleanup occurs when the stack frame is later popped. The function parameter indicates true if the job was stolen – executed on a different thread.

Fields

latch: L

func: UnsafeCell<Option<F>>

result: UnsafeCell<JobResult<R>>

Implementations

impl<L, F, R> StackJob<L, F, R>

where L: Latch + Sync, F: FnOnce(bool) -> R + Send, R: Send,

pub(crate) fn new(func: F, latch: L) -> StackJob<L, F, R>

pub(crate) unsafe fn as_job_ref(&self) -> JobRef

pub(crate) unsafe fn run_inline(self, stolen: bool) -> R

pub(crate) unsafe fn into_result(self) -> R

Trait Implementations

impl<L, F, R> Job for StackJob<L, F, R>

where L: Latch + Sync, F: FnOnce(bool) -> R + Send, R: Send,

unsafe fn execute(this: *const ())

Unsafe: this may be called from a different thread than the one which scheduled the job, so the implementer must ensure the appropriate traits are met, whether Send, Sync, or both.