Sha256: 96feba81ac5c2052a34b6c79eb7f93e9805fc0c144b4599b343626f44202e1ee
Contents?: true
Size: 1.35 KB
Versions: 8
Compression:
Stored size: 1.35 KB
Contents
use super::Handle; use crate::runtime::{SchedulerMetrics, WorkerMetrics}; impl Handle { pub(crate) fn num_workers(&self) -> usize { self.shared.worker_metrics.len() } pub(crate) fn num_blocking_threads(&self) -> usize { // workers are currently spawned using spawn_blocking self.blocking_spawner .num_threads() .saturating_sub(self.num_workers()) } pub(crate) fn num_idle_blocking_threads(&self) -> usize { self.blocking_spawner.num_idle_threads() } pub(crate) fn num_alive_tasks(&self) -> usize { self.shared.owned.num_alive_tasks() } cfg_64bit_metrics! { pub(crate) fn spawned_tasks_count(&self) -> u64 { self.shared.owned.spawned_tasks_count() } } pub(crate) fn scheduler_metrics(&self) -> &SchedulerMetrics { &self.shared.scheduler_metrics } pub(crate) fn worker_metrics(&self, worker: usize) -> &WorkerMetrics { &self.shared.worker_metrics[worker] } pub(crate) fn injection_queue_depth(&self) -> usize { self.shared.injection_queue_depth() } pub(crate) fn worker_local_queue_depth(&self, worker: usize) -> usize { self.shared.worker_local_queue_depth(worker) } pub(crate) fn blocking_queue_depth(&self) -> usize { self.blocking_spawner.queue_depth() } }
Version data entries
8 entries across 8 versions & 1 rubygems