BoundedBlockingQueue.cpp File Reference

Implementation of a thread-safe, bounded blocking queue. More...

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

Include dependency graph for BoundedBlockingQueue.cpp:

Go to the source code of this file.

Classes
class	BoundedBlockingQueue
	A thread-safe queue with a fixed capacity that supports blocking operations. More...

Functions
void	producerTask (BoundedBlockingQueue *q)
	Worker function for the Producer thread.
void	consumerTask (BoundedBlockingQueue *q)
	Worker function for the Consumer thread.
int	main ()
	Entry point of the program. Initializes the queue and manages the lifecycle of worker threads.

Detailed Description

Implementation of a thread-safe, bounded blocking queue.

• This file demonstrates the Producer-Consumer pattern using modern C++ synchronization primitives like std::mutex and std::condition_variable.

Definition in file BoundedBlockingQueue.cpp.

Function Documentation

consumerTask()

void consumerTask

(

BoundedBlockingQueue *

q

)

Worker function for the Consumer thread.

Parameters

q	Pointer to the shared BoundedBlockingQueue.

Definition at line 123 of file BoundedBlockingQueue.cpp.

                                           {
    for(int i=1; i<=100; ++i) {
        int val;
        bool pop_status = q->pop(val);
        if(!pop_status) {
            std::cout << "---[ConsumerTask] : SHUTDOWN DETECTED. STOPPING CONSUMPTION---" << std::endl;
            break; 
        } else {
            std::cout << "Consuming value..." << std::endl;
            std::this_thread::sleep_for(std::chrono::milliseconds(100));
        }
    }
    std::cout << "[Consumer] Finished my requirements! Triggering shutdown..." << std::endl;
    q->shut_down();
    return;
}

References BoundedBlockingQueue::pop(), and BoundedBlockingQueue::shut_down().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function:

main()

int main

(

void

)

Entry point of the program. Initializes the queue and manages the lifecycle of worker threads.

Definition at line 144 of file BoundedBlockingQueue.cpp.

           {
    BoundedBlockingQueue queue(5);
 
    std::thread producerThread(producerTask, &queue);
    std::thread consumerThread(consumerTask, &queue);
 
    if(producerThread.joinable())
        producerThread.join();
    if(consumerThread.joinable())
        consumerThread.join();
 
    std::cout << "All work finished." << std::endl;
    return 0;
}

References consumerTask(), and producerTask().

Here is the call graph for this function:

producerTask()

void producerTask

(

BoundedBlockingQueue *

q

)

Worker function for the Producer thread.

Parameters

q	Pointer to the shared BoundedBlockingQueue.

Definition at line 106 of file BoundedBlockingQueue.cpp.

                                           {
    for(int i=1; i<=30; ++i) {
        if(!q->push(i)) {
            std::cout << "[Producer] Shutdown detected. Stopping production." << std::endl;
            return;
        }
        std::this_thread::sleep_for(std::chrono::milliseconds(25));
    }
    std::cout << "[Producer] Finished all items" << std::endl;
    q->shut_down();
    return;
}

References BoundedBlockingQueue::push(), and BoundedBlockingQueue::shut_down().

Referenced by main().

Here is the call graph for this function:

Here is the caller graph for this function: