d2/d21/Queue_8hpp_source.html

#pragma once


#include <iostream>

#include <queue>

#include <mutex>

#include <condition_variable>

#include <optional>

#include "GameMessage.hpp"


class Queue {

public:

    void push(const GameMessage& item);


    std::optional<GameMessage> pop();


    GameMessage waitAndPop();


    bool isEmpty();


private:

    std::queue<GameMessage> _queue;

    std::mutex _mutex;

    std::condition_variable _condition;

};


GameMessage.hpp

Queue
A thread-safe queue for storing and managing GameMessage objects.
Definition Queue.hpp:17

Queue::push
void push(const GameMessage &item)
Push a GameMessage item into the queue.
Definition Queue.cpp:3

Queue::waitAndPop
GameMessage waitAndPop()
Wait and pop a GameMessage item from the queue. This blocks until an item is available.
Definition Queue.cpp:17

Queue::isEmpty
bool isEmpty()
Check if the queue is empty.
Definition Queue.cpp:25

Queue::pop
std::optional< GameMessage > pop()
Try to pop a GameMessage item from the queue.
Definition Queue.cpp:9

GameMessage
A structure representing a game message.
Definition GameMessage.hpp:59