Struct WorkerMetrics

#[repr(align(128))]
pub(crate) struct WorkerMetrics {
    pub(crate) busy_duration_total: MetricAtomicU64,
    pub(crate) queue_depth: MetricAtomicUsize,
    thread_id: Mutex<Option<ThreadId>>,
    pub(crate) park_count: MetricAtomicU64,
    pub(crate) park_unpark_count: MetricAtomicU64,
}

Retrieve runtime worker metrics.

Note: This is an unstable API. The public API of this type may break in 1.x releases. See the documentation on unstable features for details.

Fields

busy_duration_total: MetricAtomicU64

Amount of time the worker spent doing work vs. parking.

queue_depth: MetricAtomicUsize

Number of tasks currently in the local queue. Used only by the current-thread scheduler.

thread_id: Mutex<Option<ThreadId>>

Thread id of worker thread.

park_count: MetricAtomicU64

Number of times the worker parked.

park_unpark_count: MetricAtomicU64

Number of times the worker parked and unparked.

Implementations

impl WorkerMetrics

pub(crate) fn new() -> WorkerMetrics

pub(crate) fn set_queue_depth(&self, len: usize)

pub(crate) fn set_thread_id(&self, thread_id: ThreadId)

pub(crate) fn from_config(_: &Config) -> WorkerMetrics

Trait Implementations

impl Debug for WorkerMetrics

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for WorkerMetrics

fn default() -> WorkerMetrics

Returns the “default value” for a type.