Struct mmtk::scheduler::scheduler::GCWorkScheduler
source · pub struct GCWorkScheduler<VM: VMBinding> {
pub work_buckets: EnumMap<WorkBucketStage, WorkBucket<VM>>,
pub(crate) worker_group: Arc<WorkerGroup<VM>>,
pub(crate) worker_monitor: Arc<WorkerMonitor>,
affinity: AffinityKind,
}
Fields§
§work_buckets: EnumMap<WorkBucketStage, WorkBucket<VM>>
Work buckets
worker_group: Arc<WorkerGroup<VM>>
Workers
worker_monitor: Arc<WorkerMonitor>
For synchronized communication between workers and with mutators.
affinity: AffinityKind
How to assign the affinity of each GC thread. Specified by the user.
Implementations§
source§impl<VM: VMBinding> GCWorkScheduler<VM>
impl<VM: VMBinding> GCWorkScheduler<VM>
pub fn new(num_workers: usize, affinity: AffinityKind) -> Arc<Self>
pub fn num_workers(&self) -> usize
sourcepub fn spawn_gc_threads(
self: &Arc<Self>,
mmtk: &'static MMTK<VM>,
tls: VMThread
)
pub fn spawn_gc_threads( self: &Arc<Self>, mmtk: &'static MMTK<VM>, tls: VMThread )
Create GC threads for the first time. It will also create the GCWorker
instances.
Currently GC threads only include worker threads, and we currently have only one worker group. We may add more worker groups in the future.
sourcepub fn stop_gc_threads_for_forking(self: &Arc<Self>)
pub fn stop_gc_threads_for_forking(self: &Arc<Self>)
Ask all GC workers to exit for forking.
sourcepub fn surrender_gc_worker(&self, worker: Box<GCWorker<VM>>)
pub fn surrender_gc_worker(&self, worker: Box<GCWorker<VM>>)
Surrender the GCWorker
struct of a GC worker when it exits.
sourcepub fn respawn_gc_threads_after_forking(self: &Arc<Self>, tls: VMThread)
pub fn respawn_gc_threads_after_forking(self: &Arc<Self>, tls: VMThread)
Respawn GC threads after forking. This will reuse the GCWorker
instances of stopped
workers. tls
is the VM thread that requests GC threads to be re-spawn, and will be
passed down to crate::vm::Collection::spawn_gc_thread
.
sourcepub fn resolve_affinity(&self, thread: usize)
pub fn resolve_affinity(&self, thread: usize)
Resolve the affinity of a thread.
sourcepub(crate) fn request_schedule_collection(&self)
pub(crate) fn request_schedule_collection(&self)
Request a GC to be scheduled. Called by mutator via GCRequester
.
sourcefn add_schedule_collection_packet(&self)
fn add_schedule_collection_packet(&self)
Add the ScheduleCollection
packet. Called by the last parked worker.
sourcepub fn schedule_common_work<C: GCWorkContext<VM = VM>>(
&self,
plan: &'static C::PlanType
)
pub fn schedule_common_work<C: GCWorkContext<VM = VM>>( &self, plan: &'static C::PlanType )
Schedule all the common work packets
fn are_buckets_drained(&self, buckets: &[WorkBucketStage]) -> bool
pub fn all_buckets_empty(&self) -> bool
sourcepub(crate) fn schedule_sentinels(&self) -> bool
pub(crate) fn schedule_sentinels(&self) -> bool
Schedule “sentinel” work packets for all activated buckets.
sourcepub(crate) fn update_buckets(&self) -> bool
pub(crate) fn update_buckets(&self) -> bool
Open buckets if their conditions are met.
This function should only be called after all the workers are parked. No workers will be waked up by this function. The caller is responsible for that.
Return true if there’re any non-empty buckets updated.
pub fn deactivate_all(&self)
pub fn reset_state(&self)
pub fn debug_assert_all_buckets_deactivated(&self)
sourcepub(crate) fn assert_all_activated_buckets_are_empty(&self)
pub(crate) fn assert_all_activated_buckets_are_empty(&self)
Check if all the work buckets are empty
sourcefn poll_schedulable_work_once(
&self,
worker: &GCWorker<VM>
) -> Steal<Box<dyn GCWork<VM>>>
fn poll_schedulable_work_once( &self, worker: &GCWorker<VM> ) -> Steal<Box<dyn GCWork<VM>>>
Get a schedulable work packet without retry.
sourcefn poll_schedulable_work(
&self,
worker: &GCWorker<VM>
) -> Option<Box<dyn GCWork<VM>>>
fn poll_schedulable_work( &self, worker: &GCWorker<VM> ) -> Option<Box<dyn GCWork<VM>>>
Get a schedulable work packet.
sourcepub(crate) fn poll(
&self,
worker: &GCWorker<VM>
) -> Result<Box<dyn GCWork<VM>>, WorkerShouldExit>
pub(crate) fn poll( &self, worker: &GCWorker<VM> ) -> Result<Box<dyn GCWork<VM>>, WorkerShouldExit>
Called by workers to get a schedulable work packet. Park the worker if there’re no available packets.
fn poll_slow( &self, worker: &GCWorker<VM> ) -> Result<Box<dyn GCWork<VM>>, WorkerShouldExit>
sourcefn on_last_parked(
&self,
worker: &GCWorker<VM>,
goals: &mut WorkerGoals
) -> LastParkedResult
fn on_last_parked( &self, worker: &GCWorker<VM>, goals: &mut WorkerGoals ) -> LastParkedResult
Called when the last worker parked. goal
allows this function to inspect and change the
current goal.
sourcefn respond_to_requests(
&self,
worker: &GCWorker<VM>,
goals: &mut WorkerGoals
) -> LastParkedResult
fn respond_to_requests( &self, worker: &GCWorker<VM>, goals: &mut WorkerGoals ) -> LastParkedResult
Respond to a worker reqeust.
sourcefn find_more_work_for_workers(&self) -> bool
fn find_more_work_for_workers(&self) -> bool
Find more work for workers to do. Return true if more work is available.
sourcefn on_gc_finished(&self, worker: &GCWorker<VM>)
fn on_gc_finished(&self, worker: &GCWorker<VM>)
Called when GC has finished, i.e. when all work packets have been executed.
pub fn enable_stat(&self)
pub fn statistics(&self) -> HashMap<String, String>
pub fn notify_mutators_paused(&self, mmtk: &'static MMTK<VM>)
Trait Implementations§
impl<VM: VMBinding> Sync for GCWorkScheduler<VM>
Auto Trait Implementations§
impl<VM> !RefUnwindSafe for GCWorkScheduler<VM>
impl<VM> Send for GCWorkScheduler<VM>
impl<VM> Unpin for GCWorkScheduler<VM>
impl<VM> !UnwindSafe for GCWorkScheduler<VM>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Box<dyn Trait>
(where Trait: Downcast
) to Box<dyn Any>
. Box<dyn Any>
can
then be further downcast
into Box<ConcreteType>
where ConcreteType
implements Trait
.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Rc<Trait>
(where Trait: Downcast
) to Rc<Any>
. Rc<Any>
can then be
further downcast
into Rc<ConcreteType>
where ConcreteType
implements Trait
.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
&Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &Any
’s vtable from &Trait
’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
&mut Trait
(where Trait: Downcast
) to &Any
. This is needed since Rust cannot
generate &mut Any
’s vtable from &mut Trait
’s.§impl<T> DowncastSync for T
impl<T> DowncastSync for T
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more