Struct mmtk::scheduler::Worker

pub struct Worker<C: Context> {
    pub tls: OpaquePointer,
    pub ordinal: usize,
    pub parked: AtomicBool,
    pub local_work_bucket: WorkBucket<C>,
    pub sender: Sender<CoordinatorMessage<C>>,
    pub stat: WorkerLocalStat,
    // some fields omitted
}

Fields

tls: OpaquePointer

ordinal: usize

parked: AtomicBool

local_work_bucket: WorkBucket<C>

sender: Sender<CoordinatorMessage<C>>

stat: WorkerLocalStat

Implementations

impl<C: Context> Worker<C>

pub fn new(
    ordinal: usize,
    scheduler: Weak<Scheduler<C>>,
    is_coordinator: bool
) -> Self

pub fn add_work(&mut self, bucket: WorkBucketStage, work: impl Work<C>)

pub fn is_parked(&self) -> bool

pub fn is_coordinator(&self) -> bool

pub fn scheduler(&self) -> &Scheduler<C>

pub unsafe fn local<W: 'static + WorkerLocal>(&mut self) -> &mut W

Safety

The user needs to guarantee that the type supplied here is the same type used to create this pointer.

pub fn set_local(&mut self, local: WorkerLocalPtr)

pub fn init(&mut self, tls: OpaquePointer)

pub fn do_work(&'static mut self, work: impl Work<C>)

pub fn run(&mut self, context: &'static C)

Trait Implementations

impl<C: Context> Send for Worker<C>

impl<C: Context> Sync for Worker<C>