Struct mmtk::scheduler::Scheduler

pub struct Scheduler<C: Context> {
    pub work_buckets: EnumMap<WorkBucketStage, WorkBucket<C>>,
    pub coordinator_work: WorkBucket<C>,
    pub worker_monitor: Arc<(Mutex<()>, Condvar)>,
    pub channel: (Sender<CoordinatorMessage<C>>, Receiver<CoordinatorMessage<C>>),
    // some fields omitted
}

Fields

work_buckets: EnumMap<WorkBucketStage, WorkBucket<C>>

coordinator_work: WorkBucket<C>

Work for the coordinator thread

worker_monitor: Arc<(Mutex<()>, Condvar)>

Condition Variable for worker synchronization

channel: (Sender<CoordinatorMessage<C>>, Receiver<CoordinatorMessage<C>>)

A message channel to send new coordinator work and other actions to the coordinator thread

Implementations

impl<C: Context> Scheduler<C>

pub fn new() -> Arc<Self>

pub fn num_workers(&self) -> usize

pub fn initialize(
    self: &'static Arc<Self>,
    num_workers: usize,
    context: &'static C,
    tls: OpaquePointer
)

pub fn initialize_worker(self: &Arc<Self>, tls: OpaquePointer)

pub fn set_initializer<W: CoordinatorWork<C>>(&self, w: Option<W>)

pub fn set_finalizer<W: CoordinatorWork<C>>(&self, w: Option<W>)

pub fn worker_group(&self) -> Arc<WorkerGroup<C>>

pub fn wait_for_completion(&self)

Drain the message queue and execute coordinator work

pub fn deactivate_all(&self)

pub fn reset_state(&self)

pub fn add_coordinator_work(
    &self,
    work: impl CoordinatorWork<C>,
    worker: &Worker<C>
)

pub fn poll(&self, worker: &Worker<C>) -> Box<dyn Work<C>>

Get a scheduable work. Called by workers

pub fn enable_stat(&self)

pub fn statistics(&self) -> HashMap<String, String>

impl<VM: VMBinding> Scheduler<MMTK<VM>>

pub fn notify_mutators_paused(&self, mmtk: &'static MMTK<VM>)

Trait Implementations

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

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