Struct mmtk::scheduler::worker::GCWorkerShared

pub struct GCWorkerShared<VM: VMBinding> {
    stat: AtomicRefCell<WorkerLocalStat<VM>>,
    live_bytes: AtomicUsize,
    pub designated_work: ArrayQueue<Box<dyn GCWork<VM>>>,
    pub stealer: Option<Stealer<Box<dyn GCWork<VM>>>>,
}

The struct has one instance per worker, but is shared between workers via the scheduler instance. This structure is used for communication between workers, e.g. adding designated work packets, stealing work packets from other workers, and collecting per-worker statistics.

Fields

stat: AtomicRefCell<WorkerLocalStat<VM>>

Worker-local statistics data.

live_bytes: AtomicUsize

Accumulated bytes for live objects in this GC. When each worker scans objects, we increase the live bytes. We get this value from each worker at the end of a GC, and reset this counter.

designated_work: ArrayQueue<Box<dyn GCWork<VM>>>

A queue of GCWork that can only be processed by the owned thread.

stealer: Option<Stealer<Box<dyn GCWork<VM>>>>

Handle for stealing packets from the current worker

Implementations

impl<VM: VMBinding> GCWorkerShared<VM>

pub fn new(stealer: Option<Stealer<Box<dyn GCWork<VM>>>>) -> Self

pub(crate) fn increase_live_bytes(&self, bytes: usize)

pub(crate) fn get_and_clear_live_bytes(&self) -> usize

impl<VM: VMBinding> GCWorkerShared<VM>

pub fn borrow_stat(&self) -> AtomicRef<'_, WorkerLocalStat<VM>>

pub fn borrow_stat_mut(&self) -> AtomicRefMut<'_, WorkerLocalStat<VM>>

Trait Implementations

impl<VM: VMBinding> Send for GCWorkerShared<VM>

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