Struct mmtk::scheduler::worker::WorkerGroup

pub(crate) struct WorkerGroup<VM: VMBinding> {
    pub workers_shared: Vec<Arc<GCWorkerShared<VM>>>,
    state: Mutex<Option<WorkerCreationState<VM>>>,
}

A worker group to manage all the GC workers.

Fields

workers_shared: Vec<Arc<GCWorkerShared<VM>>>

Shared worker data

state: Mutex<Option<WorkerCreationState<VM>>>

The stateful part. None means state transition is underway.

Implementations

impl<VM: VMBinding> WorkerGroup<VM>

pub fn new(num_workers: usize) -> Arc<Self>

Create a WorkerGroup

pub fn initial_spawn(&self, tls: VMThread, mmtk: &'static MMTK<VM>)

Spawn GC worker threads for the first time.

pub fn respawn(&self, tls: VMThread)

Respawn GC threads after stopping for forking.

fn create_workers( &self, local_work_queues: Vec<Worker<Box<dyn GCWork<VM>>>>, mmtk: &'static MMTK<VM> ) -> Vec<Box<GCWorker<VM>>>

Create GCWorker instances.

fn spawn(&self, workers: Vec<Box<GCWorker<VM>>>, tls: VMThread)

Spawn all the worker threads

pub fn prepare_surrender_buffer(&self)

Prepare the buffer for workers to surrender their GCWorker structs.

pub fn surrender_gc_worker(&self, worker: Box<GCWorker<VM>>) -> bool

Return the GCWorker struct to the worker group. This function returns true if all workers returned their GCWorker structs.

pub fn worker_count(&self) -> usize

Get the number of workers in the group

pub fn has_designated_work(&self) -> bool

Return true if there’re any pending designated work

pub fn get_and_clear_worker_live_bytes(&self) -> usize

Trait Implementations

impl<VM: VMBinding> Sync for WorkerGroup<VM>

We have to persuade Rust that WorkerGroup is safe to share because the compiler thinks one worker can refer to another worker via the path “worker -> scheduler -> worker_group -> Surrendered::workers -> worker” which is cyclic reference and unsafe.