PriorityThreadPool Class Reference

A pool of worker threads that retrieves tasks based on priority. More...

Collaboration diagram for PriorityThreadPool:

Public Member Functions
	PriorityThreadPool (size_t num_threads)
	Initializes the pool and starts worker threads.
void	enqueue (int priority, std::function< void()> f)
	Submits a task with a specific priority level.
	~PriorityThreadPool ()
	Gracefully joins all worker threads after processing remaining tasks.

Detailed Description

A pool of worker threads that retrieves tasks based on priority.

• Unlike a standard FIFO (First-In-First-Out) thread pool, this class uses a heap-based queue to prioritize certain tasks over others.

Definition at line 45 of file Priority.cpp.

Constructor & Destructor Documentation

PriorityThreadPool()

PriorityThreadPool::PriorityThreadPool ( size_t  num_threads )

inline

Initializes the pool and starts worker threads.

Parameters

num_threads

The number of worker threads to maintain.

Definition at line 86 of file Priority.cpp.

                                           : stop(false) {
        for (size_t i = 0; i < num_threads; ++i) {
            workers.emplace_back(&PriorityThreadPool::workerLoop, this);
        }
    }

~PriorityThreadPool()

PriorityThreadPool::~PriorityThreadPool ( )

inline

Gracefully joins all worker threads after processing remaining tasks.

Definition at line 108 of file Priority.cpp.

                          {
        stop = true;
        cv.notify_all();
        for (auto &w : workers) if (w.joinable()) w.join();
    }

Member Function Documentation

enqueue()

void PriorityThreadPool::enqueue ( int  priority, std::function< void()>  f  )

inline

Submits a task with a specific priority level.

Parameters

priority	Importance level (e.g., 10 for urgent, 1 for background).
f	The function or lambda to execute.

Definition at line 97 of file Priority.cpp.

                                                      {
        {
            std::unique_lock<std::mutex> lock(queue_mtx);
            tasks.push({priority, std::move(f)});
        }
        cv.notify_one();
    }

Referenced by main().

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• ThreadPools/Priority.cpp