atomic_context_ptr typedef | cubthread::worker_pool< Context > | private |
context_manager_type typedef | cubthread::worker_pool< Context > | |
context_type typedef | cubthread::worker_pool< Context > | |
core class | cubthread::worker_pool< Context > | friend |
er_log_stats(void) const | cubthread::worker_pool< Context > | |
execute(task_type *work_arg) | cubthread::worker_pool< Context > | |
execute_on_core(task_type *work_arg, std::size_t core_hash) | cubthread::worker_pool< Context > | |
get_core_count(void) const | cubthread::worker_pool< Context > | |
get_max_count(void) const | cubthread::worker_pool< Context > | |
get_round_robin_core_hash(void) | cubthread::worker_pool< Context > | private |
get_stats(cubperf::stat_value *stats_out) const | cubthread::worker_pool< Context > | |
get_wait_for_task_time() const | cubthread::worker_pool< Context > | inline |
is_full(void) const | cubthread::worker_pool< Context > | inline |
is_pooling_threads() const | cubthread::worker_pool< Context > | inline |
is_running(void) const | cubthread::worker_pool< Context > | |
m_context_manager | cubthread::worker_pool< Context > | private |
m_core_array | cubthread::worker_pool< Context > | private |
m_core_count | cubthread::worker_pool< Context > | private |
m_log | cubthread::worker_pool< Context > | private |
m_max_workers | cubthread::worker_pool< Context > | private |
m_name | cubthread::worker_pool< Context > | private |
m_pool_threads | cubthread::worker_pool< Context > | private |
m_round_robin_counter | cubthread::worker_pool< Context > | private |
m_stopped | cubthread::worker_pool< Context > | private |
m_task_count | cubthread::worker_pool< Context > | private |
m_task_max_count | cubthread::worker_pool< Context > | private |
m_wait_for_task_time | cubthread::worker_pool< Context > | private |
map_cores(Func &&func, Args &&...args) | cubthread::worker_pool< Context > | |
map_running_contexts(Func &&func, Args &&...args) | cubthread::worker_pool< Context > | |
start_all_workers(void) | cubthread::worker_pool< Context > | |
stop_execution(void) | cubthread::worker_pool< Context > | |
task_type typedef | cubthread::worker_pool< Context > | |
try_execute(task_type *work_arg) | cubthread::worker_pool< Context > | |
worker_pool(std::size_t pool_size, std::size_t task_max_count, context_manager_type &context_mgr, const char *name, std::size_t core_count=1, bool debug_logging=false, bool pool_threads=false, wait_seconds wait_for_task_time=std::chrono::seconds(5)) | cubthread::worker_pool< Context > | |
~worker_pool() | cubthread::worker_pool< Context > | |