thread_pool.h File Reference

Core thread pool implementation with work stealing and auto-scaling. More...

#include <kcenon/thread/utils/formatter.h>
#include <kcenon/thread/utils/formatter_macros.h>
#include <kcenon/thread/core/job_queue.h>
#include <kcenon/thread/core/thread_worker.h>
#include <kcenon/thread/core/cancellation_token.h>
#include <kcenon/thread/utils/convert_string.h>
#include <kcenon/thread/forward.h>
#include <kcenon/thread/interfaces/thread_context.h>
#include <kcenon/thread/interfaces/pool_queue_adapter.h>
#include <kcenon/thread/metrics/thread_pool_metrics.h>
#include <kcenon/thread/metrics/enhanced_metrics.h>
#include <kcenon/thread/metrics/metrics_service.h>
#include <kcenon/thread/pool_policies/pool_policy.h>
#include <kcenon/thread/core/submit_options.h>
#include "config.h"
#include <tuple>
#include <string>
#include <memory>
#include <mutex>
#include <vector>
#include <chrono>
#include <optional>
#include <future>
#include <type_traits>
#include <kcenon/thread/core/thread_pool_impl.h>
#include <kcenon/thread/core/thread_pool_fmt.h>

Include dependency graph for thread_pool.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
class	kcenon::thread::thread_pool
	A thread pool for concurrent execution of jobs using multiple worker threads. More...

Namespaces
namespace	kcenon
namespace	kcenon::thread
	Core threading foundation of the thread system library.
namespace	kcenon::thread::diagnostics

Macros
#define	KCENON_HAS_COMMON_EXECUTOR   0
#define	KCENON_THREAD_INTERNAL_INCLUDE

Typedefs
using	kcenon::thread::standard_queue
	Standard mutex-based unbounded queue.
using	kcenon::thread::policy_lockfree_queue
	Lock-free unbounded queue.

Detailed Description

Core thread pool implementation with work stealing and auto-scaling.

#include <kcenon/thread/core/thread_pool.h>
 
// Create a thread pool with 4 workers
auto pool = std::make_shared<kcenon::thread::thread_pool>("my_pool", 4);
 
// Submit a task
pool->enqueue([] { std::cout << "Task executed\n"; });
 
// Submit a task with a result
auto future = pool->enqueue([] { return 42; });
int result = future.get();
 
// Graceful shutdown (waits for pending tasks)
pool->stop();

Definition in file thread_pool.h.

Macro Definition Documentation

KCENON_HAS_COMMON_EXECUTOR

#define KCENON_HAS_COMMON_EXECUTOR   0

Definition at line 60 of file thread_pool.h.

KCENON_THREAD_INTERNAL_INCLUDE

#define KCENON_THREAD_INTERNAL_INCLUDE

Definition at line 825 of file thread_pool.h.