|
Thread System 0.3.1
High-performance C++20 thread pool with work stealing and DAG scheduling
|
Classes | |
| struct | bottleneck_report |
| Analysis report of bottlenecks in the thread pool. More... | |
| struct | component_health |
| Health status of a single component. More... | |
| struct | diagnostics_config |
| Configuration options for thread pool diagnostics. More... | |
| class | execution_event_listener |
| Interface for receiving job execution events. More... | |
| struct | health_status |
| Comprehensive health status of the thread pool. More... | |
| struct | health_thresholds |
| Configurable thresholds for health status determination. More... | |
| struct | job_execution_event |
| Event data for job execution tracing. More... | |
| struct | job_info |
| Information about a job in the thread pool. More... | |
| struct | thread_info |
| Information about a worker thread in the pool. More... | |
| class | thread_pool_diagnostics |
| Comprehensive diagnostics API for thread pool monitoring. More... | |
Functions | |
| auto | bottleneck_type_to_string (bottleneck_type type) -> std::string |
| Converts bottleneck_type to human-readable string. | |
| auto | event_type_to_string (event_type type) -> std::string |
| Converts event_type to human-readable string. | |
| auto | health_state_to_string (health_state state) -> std::string |
| Converts health_state to human-readable string. | |
| auto | health_state_to_http_code (health_state state) -> int |
| Gets HTTP status code for health state. | |
| auto | job_status_to_string (job_status status) -> std::string |
| Converts job_status to human-readable string. | |
| auto | worker_state_to_string (worker_state state) -> std::string |
| Converts worker_state to human-readable string. | |
|
inlinenodiscard |
Converts bottleneck_type to human-readable string.
| type | The bottleneck type to convert. |
Definition at line 47 of file bottleneck_report.h.
References lock_contention, memory_pressure, none, queue_full, slow_consumer, uneven_distribution, and worker_starvation.
Referenced by kcenon::thread::diagnostics::bottleneck_report::to_json(), kcenon::thread::diagnostics::thread_pool_diagnostics::to_json(), and kcenon::thread::diagnostics::bottleneck_report::to_string().

|
inlinenodiscard |
Converts event_type to human-readable string.
| type | The event type to convert. |
Definition at line 51 of file execution_event.h.
References cancelled, completed, dequeued, enqueued, failed, retried, and started.
Referenced by kcenon::thread::diagnostics::job_execution_event::to_json(), and kcenon::thread::diagnostics::job_execution_event::to_string().

|
inlinenodiscard |
Gets HTTP status code for health state.
Useful for implementing health check HTTP endpoints.
| state | The health state. |
Definition at line 122 of file health_status.h.
References degraded, healthy, unhealthy, and unknown.
Referenced by kcenon::thread::diagnostics::health_status::http_status_code().

|
inlinenodiscard |
Converts health_state to human-readable string.
| state | The state to convert. |
Definition at line 103 of file health_status.h.
References degraded, healthy, unhealthy, and unknown.
Referenced by kcenon::thread::diagnostics::health_status::to_json(), kcenon::thread::diagnostics::thread_pool_diagnostics::to_json(), and kcenon::thread::diagnostics::health_status::to_string().

|
inlinenodiscard |
Converts job_status to human-readable string.
| status | The status to convert. |
Definition at line 47 of file job_info.h.
References cancelled, completed, failed, pending, running, and timed_out.
Referenced by kcenon::thread::diagnostics::job_info::to_json(), and kcenon::thread::diagnostics::job_info::to_string().

|
inlinenodiscard |
Converts worker_state to human-readable string.
| state | The state to convert. |
Definition at line 47 of file thread_info.h.
References active, idle, stopped, and stopping.
Referenced by kcenon::thread::diagnostics::thread_pool_diagnostics::format_thread_dump(), kcenon::thread::diagnostics::thread_info::to_json(), and kcenon::thread::diagnostics::thread_info::to_string().
