ResultQueue< T > Class Template Reference

A thread-safe template queue used for inter-thread communication. More...

Collaboration diagram for ResultQueue< T >:

Public Member Functions
void	push (T result)
	Pushes a result into the queue and notifies the waiting thread.
T	pop ()
	Blocks until a result is available and then removes it from the queue.

Detailed Description

template<typename T>
class ResultQueue< T >

A thread-safe template queue used for inter-thread communication.

• This acts as the "Inbox." Producers (workers) push results into it, and the Consumer (main thread) pops them out.

  Template Parameters

  T	The type of data being passed between threads.

Definition at line 26 of file MessagePassing.cpp.

Member Function Documentation

pop()

template<typename T >

T ResultQueue< T >::pop ( )

inline

Blocks until a result is available and then removes it from the queue.

Returns

T The retrieved result object.

Definition at line 49 of file MessagePassing.cpp.

            {
        std::unique_lock<std::mutex> lock(mtx);
        // Wait until the inbox is not empty
        cv.wait(lock, [this] { return !this->queue.empty(); });
        T val = std::move(this->queue.front());
        queue.pop();
        return val;
    }

Referenced by main().

Here is the caller graph for this function:

push()

template<typename T >

void ResultQueue< T >::push ( T  result )

inline

Pushes a result into the queue and notifies the waiting thread.

Parameters

result

The data object to be sent to the inbox.

Definition at line 37 of file MessagePassing.cpp.

                        {
        {
            std::lock_guard<std::mutex> lock(mtx);
            queue.push(result);
        }
        cv.notify_one(); 
    }

Referenced by IsPrimeCalculator::operator()().

Here is the caller graph for this function:

---

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

• ThreadPools/MessagePassing.cpp