Priority.cpp File Reference

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

Include dependency graph for Priority.cpp:

Go to the source code of this file.

Classes
struct	PriorityTask
	A wrapper for a callable task associated with a priority level. More...
class	PriorityThreadPool
	A pool of worker threads that retrieves tasks based on priority. More...
struct	PaymentTask
	A Functor simulating a financial processing task. More...

Functions
int	main ()
	Main function demonstrating priority-based out-of-order execution.

Function Documentation

main()

int main

(

void

)

Main function demonstrating priority-based out-of-order execution.

Definition at line 134 of file Priority.cpp.

           {
    // We use 1 thread to force tasks to wait in the queue, making 
    // the priority ordering visible in the console output.
    PriorityThreadPool pool(1); 
 
    std::cout << "Submitting tasks in random order...\n";
 
    // Submit Low Priority first
    pool.enqueue(1, PaymentTask{"Low: Reward Statement"});
    pool.enqueue(1, PaymentTask{"Low: SMS Notification"});
 
    // Submit High Priority last
    pool.enqueue(10, PaymentTask{"HIGH: FRAUD DETECTION"});
    pool.enqueue(10, PaymentTask{"HIGH: AUTHORIZATION"});
 
    // The output will show HIGH priority tasks running before the LOW priority 
    // tasks that were added earlier.
    
    std::this_thread::sleep_for(std::chrono::seconds(2));
    return 0;
}

References PriorityThreadPool::enqueue().

Here is the call graph for this function: