BasicThreadPool.cpp File Reference

A basic implementation of a persistent Worker Thread Pool. More...

#include <iostream>
#include <vector>
#include <thread>
#include <functional>
#include <mutex>
#include <queue>
#include <condition_variable>
#include <atomic>
#include <chrono>

Include dependency graph for BasicThreadPool.cpp:

Go to the source code of this file.

Classes
class	ThreadPool
	Manages a collection of threads that execute tasks from a shared queue. More...

Typedefs
typedef std::function< void()>	Task

Functions
void	dataProcessingTask (int id)
	Simulates a CPU-bound data processing task.
int	main ()
	Main function demonstrating mass task submission.

Variables
std::mutex	log_mtx
	Global mutex for synchronized console logging.

Detailed Description

A basic implementation of a persistent Worker Thread Pool.

• This file demonstrates the core architecture of a thread pool: a fixed number of threads waiting on a shared task queue using a Monitor Pattern (Mutex + Condition Variable).

Definition in file BasicThreadPool.cpp.

Typedef Documentation

Task

typedef std::function<void()> Task

Definition at line 23 of file BasicThreadPool.cpp.

Function Documentation

dataProcessingTask()

void dataProcessingTask

(

int

id

)

Simulates a CPU-bound data processing task.

Parameters

id	The task identifier.

Definition at line 123 of file BasicThreadPool.cpp.

                                {
    {
        std::lock_guard<std::mutex> lock(log_mtx);
        std::cout << "[Task " << id << "] is being processed by a worker..." << std::endl;
    }
    std::this_thread::sleep_for(std::chrono::milliseconds(300));
}

References log_mtx.

Referenced by main().

Here is the caller graph for this function:

main()

int main

(

void

)

Main function demonstrating mass task submission.

Definition at line 134 of file BasicThreadPool.cpp.

           {
    ThreadPool pool(12);
 
    {
        std::lock_guard<std::mutex> lock(log_mtx);
        std::cout << "--- System Initialized with 12 Worker Threads ---" << std::endl;
    }
 
    // Submit 1000 tasks
    for (int i = 1; i <= 1000; ++i) {
        pool.enqueue(std::bind(dataProcessingTask, i));
    }
 
    std::this_thread::sleep_for(std::chrono::seconds(5));
    
    return 0;
}

References dataProcessingTask(), ThreadPool::enqueue(), and log_mtx.

Here is the call graph for this function:

Variable Documentation

log_mtx

std::mutex log_mtx

Global mutex for synchronized console logging.

Definition at line 28 of file BasicThreadPool.cpp.

Referenced by dataProcessingTask(), and main().