CDPThreadPool pool(4);  // Creates a pool with 4 threads
pool.Post([](){ std::cout << "Task 1" << std::endl; });
pool.Post([](){ std::cout << "Task 2" << std::endl; });
pool.Join();  // Wait for all tasks to complete

Member Function Documentation

CDPThreadPool::CDPThreadPool(std::size_t numThreads, std::size_t threadStackSize = 64 * 1024, CDP::ThreadPriority priority = CDP::LowThreadPriority, const std::string &threadBaseName = "CTPool")

Constructs a CDPThreadPool object with the specified number of threads, thread stack size, thread priority, and thread base name.

numThreads The number of threads in the pool. threadStackSize The stack size for each thread. priority The priority of threads. threadBaseName The base name for threads.

CDPThreadPool::~CDPThreadPool()

Destroys the CDPThreadPool object and ensures all threads have completed execution.

void CDPThreadPool::Await(double seconds)

Blocks the calling thread for the specified number of seconds or until all tasks have completed execution, whichever comes first.

seconds The number of seconds to wait.

std::size_t CDPThreadPool::GetThreadCount()

Returns the number of threads in the thread pool.

Returns the number of threads.

CDP::ThreadPriority CDPThreadPool::GetThreadPriority()

Returns the priority of threads in the thread pool.

Returns the thread priority.

std::size_t CDPThreadPool::GetThreadStackSize()

Returns the stack size of threads in the thread pool.

Returns the stack size.

bool CDPThreadPool::IsStopped()

Returns whether the thread pool has been stopped.

Returns true if the thread pool has been stopped; otherwise false.

void CDPThreadPool::Join()

Blocks the calling thread until all tasks have completed execution.

void CDPThreadPool::Post(std::function<void() > task)

Submits a task for execution by the thread pool.

task A function object representing the task to be executed.

void CDPThreadPool::Stop()

Stops the thread pool from executing any more tasks.