Class JobStats

Nested Relationships

Nested Types

Class Documentation

class JobStats

Public Types

enum class QueueType

Values:

enumerator Local
enumerator Stealable
enumerator Global

Public Functions

explicit JobStats(size_t num_threads)
void record_work_submitted(size_t worker_id, JobPriority priority, size_t count = 1)
void record_work_executed(size_t worker_id, size_t duration_ns)
void record_steal_attempt(size_t worker_id, bool success, size_t work_stolen)
void record_work_stolen_from_me(size_t worker_id, size_t count)
void record_queue_depth(size_t worker_id, size_t local_depth, size_t stealable_depth)
void record_idle_spin(size_t worker_id)
void record_idle_time(size_t worker_id, size_t duration_ns)
void record_queue_hit(size_t worker_id, QueueType type)
GlobalStats aggregate()
void reset()
void log() const
const std::vector<ThreadStats> &get_thread_stats() const
const GlobalStats &get_global_stats() const
struct GlobalStats

Public Members

size_t total_work_executed = 0
size_t total_work_submitted = 0
size_t total_work_time_ns = 0
double average_work_time_us = 0.0
size_t min_work_time_ns = std::numeric_limits<size_t>::max()
size_t max_work_time_ns = 0
std::array<size_t, 3> work_by_priority = {0, 0, 0}
size_t total_steal_attempts = 0
size_t total_steal_successes = 0
double steal_success_rate = 0.0
double average_local_queue_depth = 0.0
double average_stealable_queue_depth = 0.0
size_t max_queue_depth = 0
size_t total_idle_spins = 0
size_t total_idle_time_ns = 0
double idle_time_percentage = 0.0
double load_imbalance = 0.0
std::chrono::steady_clock::time_point start_time
std::chrono::steady_clock::time_point last_reset
double elapsed_seconds = 0.0
struct ThreadStats

Public Members

size_t work_executed = 0

Work execution Work is a unit of uninterrupted execution within a job For example, in the following code: 

Job<> do_work()
{
  foo();
  co_await other_job();
  bar();
}
foo will be a different work unit than bar

size_t work_submitted = 0
size_t total_work_time_ns = 0
size_t min_work_time_ns = std::numeric_limits<size_t>::max()
size_t max_work_time_ns = 0
std::array<size_t, 3> work_by_priority = {0, 0, 0}
size_t steal_attempts = 0
size_t steal_successes = 0
size_t work_stolen = 0
size_t work_lost_to_thieves = 0
size_t total_queue_depth_samples = 0
size_t sum_local_queue_depth = 0
size_t sum_stealable_queue_depth = 0
size_t max_local_queue_depth = 0
size_t max_stealable_queue_depth = 0
size_t idle_spins = 0
size_t total_idle_time_ns = 0
size_t local_queue_hits = 0
size_t steal_queue_hits = 0
size_t global_queue_hits = 0