Thread System
0.3.1
High-performance C++20 thread pool with work stealing and DAG scheduling
Loading...
Searching...
No Matches
Class Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
A
adaptive_job_queue::accuracy_guard
(
kcenon::thread
)
adaptive_job_queue
(
kcenon::thread
)
adaptive_sync_policy
(
kcenon::thread::policies
)
aged_priority
(
kcenon::thread
)
aging_stats
(
kcenon::thread
)
aging_typed_job_queue_t
(
kcenon::thread
)
aging_typed_job_t
(
kcenon::thread
)
atomic_flag_wrapper
(
kcenon::thread::sync
)
atomic_shared_ptr
(
kcenon::thread
)
atomic_wait_helper
(
kcenon::thread
)
atomic_with_wait
(
kcenon::thread
)
autoscaler
(
kcenon::thread
)
autoscaling_policy
(
kcenon::thread
)
autoscaling_pool_policy
(
kcenon::thread
)
autoscaling_stats
(
kcenon::thread
)
B
BackendRegistry
(
kcenon::thread::metrics
)
backoff_calculator
(
kcenon::thread
)
backpressure_config
(
kcenon::thread
)
backpressure_job_queue
(
kcenon::thread
)
backpressure_stats
(
kcenon::thread
)
backpressure_stats_snapshot
(
kcenon::thread
)
barrier
(
kcenon::thread
)
BaseSnapshot
(
kcenon::thread::metrics
)
bottleneck_report
(
kcenon::thread::diagnostics
)
bound_policy_tag
(
kcenon::thread::policies
)
bounded_policy
(
kcenon::thread::policies
)
SlidingWindowCounter::Bucket
(
kcenon::thread::metrics
)
job_builder::built_job
(
kcenon::thread
)
C
callable_eraser
(
kcenon::thread::detail
)
callable_return_type
(
kcenon::thread::concepts
)
callable_return_type< F, std::enable_if_t< std::is_invocable_v< F > > >
(
kcenon::thread::concepts
)
crash_handler::callback_entry
(
kcenon::thread
)
callback_job
(
kcenon::thread
)
callback_typed_job_t
(
kcenon::thread
)
cancellable_future
(
kcenon::thread
)
cancellable_future< void >
(
kcenon::thread
)
cancellable_long_job
cancellation_callback_guard
(
kcenon::thread
)
cancellation_context
(
kcenon::thread
)
cancellation_reason
(
kcenon::thread
)
cancellation_scope
(
kcenon::thread
)
cancellation_token
(
kcenon::thread
)
circuit_breaker_policy
(
kcenon::thread
)
circular_array
(
kcenon::thread::lockfree
)
crash_handler::cleanup_entry
(
kcenon::thread
)
common_executor_factory
(
kcenon::thread::adapters
)
compile_string
(
kcenon::thread::detail
)
component_health
(
kcenon::thread::diagnostics
)
concurrent_queue
(
kcenon::thread::detail
)
condition_variable_wrapper
(
kcenon::thread::sync
)
conditional_feature
(
kcenon::thread::detail
)
config_builder
(
kcenon::thread
)
config_changed_event
(
kcenon::thread
)
configuration_manager
(
kcenon::thread
)
console_logger
console_monitoring
constexpr_string
(
kcenon::thread::detail
)
convert_string
(
kcenon::thread::utils
)
crash_context
(
kcenon::thread
)
crash_handler
(
kcenon::thread
)
crash_handler::crash_stats
(
kcenon::thread
)
critical_resource
D
dag_config
(
kcenon::thread
)
dag_job
(
kcenon::thread
)
dag_job_builder
(
kcenon::thread
)
dag_job_info
(
kcenon::thread
)
dag_scheduler
(
kcenon::thread
)
dag_stats
(
kcenon::thread
)
default_error_handler
(
kcenon::thread
)
demo_service
diagnostics_config
(
kcenon::thread::diagnostics
)
dynamic_bounded_policy
(
kcenon::thread::policies
)
E
enhanced_cancellation_token
(
kcenon::thread
)
enhanced_work_stealing_config
(
kcenon::thread
)
EnhancedSnapshot
(
kcenon::thread::metrics
)
EnhancedThreadPoolMetrics
(
kcenon::thread::metrics
)
enum_formatter
(
kcenon::thread::utils
)
enum_formatter
(
kcenon::thread::utils
)
error
(
kcenon::thread
)
error_handler
(
kcenon::thread
)
event_base
(
kcenon::thread
)
event_bus
(
kcenon::thread
)
execution_event_listener
(
kcenon::thread::diagnostics
)
F
formatter
(
kcenon::thread::utils
)
formatter
(
kcenon::thread::utils
)
formatter< kcenon::thread::job_queue >
(
std
)
formatter< kcenon::thread::job_queue, wchar_t >
(
std
)
formatter< kcenon::thread::job_types >
(
std
)
formatter< kcenon::thread::job_types, wchar_t >
(
std
)
formatter< kcenon::thread::thread_conditions >
(
std
)
formatter< kcenon::thread::thread_conditions, wchar_t >
(
std
)
formatter< kcenon::thread::thread_pool >
(
std
)
formatter< kcenon::thread::thread_pool, wchar_t >
(
std
)
formatter< kcenon::thread::thread_worker >
(
std
)
formatter< kcenon::thread::thread_worker, wchar_t >
(
std
)
formatter< kcenon::thread::typed_thread_pool_t< job_type > >
(
std
)
formatter< kcenon::thread::typed_thread_pool_t< job_type >, wchar_t >
(
std
)
formatter< kcenon::thread::typed_thread_worker_t< job_type > >
(
std
)
formatter< kcenon::thread::typed_thread_worker_t< job_type >, wchar_t >
(
std
)
formatter< test_priority >
(
std
)
formatter< test_priority, wchar_t >
(
std
)
function_traits
(
kcenon::thread::detail
)
function_traits< R(*)(Args...) noexcept >
(
kcenon::thread::detail
)
function_traits< R(*)(Args...)>
(
kcenon::thread::detail
)
function_traits< R(C::*)(Args...) const >
(
kcenon::thread::detail
)
function_traits< R(C::*)(Args...)>
(
kcenon::thread::detail
)
future_job
(
kcenon::thread
)
future_value_type
(
kcenon::thread::detail
)
G
global_reclamation_manager
(
kcenon::thread::detail
)
cancellation_context::guard
(
kcenon::thread
)
H
has_blocking_overflow
(
kcenon::thread
)
has_blocking_overflow< T, std::enable_if_t< policy_queue_traits< T >::is_policy_queue > >
(
kcenon::thread
)
has_bound_policy_tag
(
kcenon::thread::detail
)
has_bound_policy_tag< T, std::void_t< typename T::policy_tag > >
(
kcenon::thread::detail
)
has_bound_policy_type
(
kcenon::thread::detail
)
has_bound_policy_type< T, std::void_t< typename T::bound_policy_type > >
(
kcenon::thread::detail
)
has_do_work_method
(
kcenon::thread::detail
)
has_do_work_method< T, std::void_t< decltype(std::declval< T >().do_work())> >
(
kcenon::thread::detail
)
has_get_method
(
kcenon::thread::concepts
)
has_get_method
(
kcenon::thread::detail
)
has_get_method< T, std::void_t< decltype(std::declval< T >().get())> >
(
kcenon::thread::concepts
)
has_get_method< T, std::void_t< decltype(std::declval< T >().get())> >
(
kcenon::thread::detail
)
has_overflow_policy_tag
(
kcenon::thread::detail
)
has_overflow_policy_tag< T, std::void_t< typename T::policy_tag > >
(
kcenon::thread::detail
)
has_overflow_policy_type
(
kcenon::thread::detail
)
has_overflow_policy_type< T, std::void_t< typename T::overflow_policy_type > >
(
kcenon::thread::detail
)
has_priority_method
(
kcenon::thread::detail
)
has_priority_method< T, std::void_t< decltype(std::declval< T >().priority())> >
(
kcenon::thread::detail
)
has_sync_policy_tag
(
kcenon::thread::detail
)
has_sync_policy_tag< T, std::void_t< typename T::policy_tag > >
(
kcenon::thread::detail
)
has_sync_policy_type
(
kcenon::thread::detail
)
has_sync_policy_type< T, std::void_t< typename T::sync_policy_type > >
(
kcenon::thread::detail
)
has_wait_method
(
kcenon::thread::concepts
)
has_wait_method< T, std::void_t< decltype(std::declval< T >().wait())> >
(
kcenon::thread::concepts
)
hazard_pointer
(
kcenon::thread
)
hazard_pointer_domain
(
kcenon::thread
)
hazard_pointer_registry
(
kcenon::thread::detail
)
health_status
(
kcenon::thread::diagnostics
)
health_thresholds
(
kcenon::thread::diagnostics
)
I
is_bounded_queue
(
kcenon::thread
)
is_bounded_queue< T, std::enable_if_t< policy_queue_traits< T >::is_policy_queue > >
(
kcenon::thread
)
is_compatible_job
(
kcenon::thread::detail
)
is_compatible_job< Job, ExpectedJobType >
(
kcenon::thread::detail
)
is_duration
(
kcenon::thread::concepts
)
is_duration< std::chrono::duration< Rep, Period > >
(
kcenon::thread::concepts
)
is_error_code_enum< kcenon::thread::error_code >
(
std
)
is_future_like
(
kcenon::thread::concepts
)
is_lockfree_queue
(
kcenon::thread
)
is_lockfree_queue< T, std::enable_if_t< policy_queue_traits< T >::is_policy_queue > >
(
kcenon::thread
)
is_nothrow_callable
(
kcenon::thread::concepts
)
is_policy_queue_impl
(
kcenon::thread::detail
)
is_policy_queue_impl< policy_queue< SyncPolicy, BoundPolicy, OverflowPolicy > >
(
kcenon::thread::detail
)
is_valid_job_type
(
kcenon::thread::concepts
)
is_valid_job_type< T, std::enable_if_t< JobType< T > > >
(
kcenon::thread::concepts
)
J
job
(
kcenon::thread
)
job_builder
(
kcenon::thread
)
job_components
(
kcenon::thread
)
job_eraser
(
kcenon::thread::detail
)
job_execution_event
(
kcenon::thread::diagnostics
)
job_info
(
kcenon::thread::diagnostics
)
job_info
(
kcenon::thread
)
job_interface
(
kcenon::thread::jobs
)
job_queue
(
kcenon::thread
)
job_queue_adapter
(
kcenon::thread
)
job_type_extractor
(
kcenon::thread::detail
)
job_type_extractor< T >
(
kcenon::thread::detail
)
job_type_list
(
kcenon::thread::detail
)
job_type_traits
(
kcenon::thread::detail
)
job_validator
(
kcenon::thread::detail
)
JsonBackend
(
kcenon::thread::metrics
)
L
latch
(
kcenon::thread
)
LatencyHistogram
(
kcenon::thread::metrics
)
lifecycle_controller
(
kcenon::thread
)
lockfree_job_queue
(
kcenon::thread::detail
)
lockfree_sync_policy
(
kcenon::thread::policies
)
LockFreeStack
LoggingBackend
(
kcenon::thread::metrics
)
M
job_queue::memory_stats
(
kcenon::thread
)
metrics_service
(
kcenon::thread::metrics
)
MetricsBackend
(
kcenon::thread::metrics
)
MetricsBase
(
kcenon::thread::metrics
)
mock_logger
mock_monitoring
module_version
(
kcenon::thread
)
mock_monitoring::monitoring_stats
mutex_sync_policy
(
kcenon::thread::policies
)
N
concurrent_queue::node
(
kcenon::thread::detail
)
lockfree_job_queue::node
(
kcenon::thread::detail
)
lockfree_sync_policy::node
(
kcenon::thread::policies
)
lockfree_job_queue::node_pool
(
kcenon::thread::detail
)
non_cancellable_job
numa_node
(
kcenon::thread
)
numa_thread_pool
(
kcenon::thread
)
numa_topology
(
kcenon::thread
)
numa_work_stealer
(
kcenon::thread
)
O
operation_cancelled_exception
(
kcenon::thread
)
overflow_block_policy
(
kcenon::thread::policies
)
overflow_drop_newest_policy
(
kcenon::thread::policies
)
overflow_drop_oldest_policy
(
kcenon::thread::policies
)
overflow_policy_tag
(
kcenon::thread::policies
)
overflow_reject_policy
(
kcenon::thread::policies
)
overflow_timeout_policy
(
kcenon::thread::policies
)
P
performance_alert_event
(
kcenon::thread
)
policy_queue
(
kcenon::thread
)
policy_queue_adapter
(
kcenon::thread
)
policy_queue_traits
(
kcenon::thread
)
policy_queue_traits< T, std::enable_if_t< detail::has_sync_policy_type< T >::value &&detail::has_bound_policy_type< T >::value &&detail::has_overflow_policy_type< T >::value > >
(
kcenon::thread
)
thread_system_config::pool_config
(
kcenon::thread
)
pool_future
(
kcenon::thread
)
pool_policy
(
kcenon::thread
)
pool_promise
(
kcenon::thread
)
pool_promise< void >
(
kcenon::thread
)
pool_queue_adapter_interface
(
kcenon::thread
)
priority_aging_config
(
kcenon::thread
)
priority_comparator
(
kcenon::thread::detail
)
PrometheusBackend
(
kcenon::thread::metrics
)
protected_job
(
kcenon::thread
)
Q
queue_capabilities
(
kcenon::thread
)
queue_capabilities_interface
(
kcenon::thread
)
queue_factory
(
kcenon::thread
)
queue_type_selector
(
kcenon::thread
)
R
queue_factory::requirements
(
kcenon::thread
)
thread_system_config::resilience_config
(
kcenon::thread
)
result
(
kcenon::thread
)
result< void >
(
kcenon::thread
)
result_void
(
kcenon::thread
)
retire_node
(
kcenon::thread::detail
)
retry_policy
(
kcenon::thread
)
S
safe_hazard_guard
(
kcenon::thread
)
safe_hazard_pointer_domain
(
kcenon::thread
)
safe_hazard_pointer_record
(
kcenon::thread
)
sample_monitoring
autoscaling_policy::scale_down_config
(
kcenon::thread
)
autoscaling_policy::scale_up_config
(
kcenon::thread
)
thread_system_config::scaling_config
(
kcenon::thread
)
scaling_decision
(
kcenon::thread
)
scaling_metrics_sample
(
kcenon::thread
)
scheduler_interface
(
kcenon::thread
)
scoped_crash_callback
(
kcenon::thread
)
scoped_lock_guard
(
kcenon::thread::sync
)
scoped_service
(
kcenon::thread
)
service_container
(
kcenon::thread
)
service_container::service_entry
(
kcenon::thread
)
service_registry
(
kcenon::thread
)
shared_mutex_wrapper
(
kcenon::thread::sync
)
SlidingWindowCounter
(
kcenon::thread::metrics
)
SmartJobProcessor
ThreadPoolMetrics::Snapshot
(
kcenon::thread::metrics
)
span
(
kcenon::thread::utils
)
enhanced_cancellation_token::state
(
kcenon::thread
)
adaptive_job_queue::stats
(
kcenon::thread
)
hazard_pointer_domain::stats
(
kcenon::thread
)
steal_backoff_config
(
kcenon::thread
)
submit_options
(
kcenon::thread
)
event_bus::subscription
(
kcenon::thread
)
sync_policy_tag
(
kcenon::thread::policies
)
system_info
(
kcenon::thread::platform
)
system_shutdown_event
(
kcenon::thread
)
system_startup_event
(
kcenon::thread
)
T
TestData
TestNode
thread_base
(
kcenon::thread
)
thread_context
(
kcenon::thread
)
thread_context_builder
(
kcenon::thread
)
thread_error_category
(
kcenon::thread
)
thread_hazard_list
(
kcenon::thread::detail
)
thread_impl
(
kcenon::thread::detail
)
thread_info
(
kcenon::thread::diagnostics
)
thread_logger
(
kcenon::thread
)
thread_pool
(
kcenon::thread
)
thread_pool_builder
(
kcenon::thread
)
thread_pool_crash_safety
(
kcenon::thread
)
thread_pool_diagnostics
(
kcenon::thread::diagnostics
)
thread_pool_executor_adapter
(
kcenon::thread::adapters
)
hazard_pointer_domain::thread_retire_list
(
kcenon::thread
)
thread_system_config
(
kcenon::thread
)
thread_worker
(
kcenon::thread
)
ThreadPoolMetrics
(
kcenon::thread::metrics
)
token_bucket
(
kcenon::thread
)
cancellation_token::token_state
(
kcenon::thread
)
typed_job_factory_interface
(
kcenon::thread
)
typed_job_interface
(
kcenon::thread
)
typed_job_t
(
kcenon::thread
)
typed_safe_hazard_domain
(
kcenon::thread
)
typed_thread_pool_builder
(
kcenon::thread
)
typed_thread_pool_t
(
kcenon::thread
)
typed_thread_worker_t
(
kcenon::thread
)
U
unbounded_policy
(
kcenon::thread::policies
)
V
validate_thread_count
(
kcenon::thread::detail
)
validation_result
(
kcenon::thread
)
callable_eraser::vtable_t
(
kcenon::thread::detail
)
job_eraser::vtable_t
(
kcenon::thread::detail
)
W
work_affinity_tracker
(
kcenon::thread
)
work_stealing_deque
(
kcenon::thread::lockfree
)
work_stealing_pool_policy
(
kcenon::thread
)
work_stealing_stats
(
kcenon::thread
)
work_stealing_stats_snapshot
(
kcenon::thread
)
worker_policy
(
kcenon::thread
)
WorkerMetrics
(
kcenon::thread::metrics
)
Generated by
1.12.0
1.12.0 1.12.0