queue.h

Go to the documentation of this file.

/*****************************************
 * This file is documented for Doxygen.
 * If you modify this file please update
 * the comments so that Doxygen will still
 * be able to work.
 ****************************************/
#ifndef QUEUE_H
#define QUEUE_H

#include <baseclass.h>
#include <json.h>

#include <memory>
#include <mutex>
#include <string>
#include <queue>

namespace glass3 {
namespace util {
class Queue : public util::BaseClass {
 public:
    Queue();

    ~Queue();

    void clear() override;

    bool addDataToQueue(std::shared_ptr<json::Object> data);

    std::shared_ptr<json::Object> getDataFromQueue();

    int size();

 private:
    std::queue<std::shared_ptr<json::Object>> m_DataQueue;

    std::mutex & getMutex();

    std::mutex m_Mutex;
};
}  // namespace util
}  // namespace glass3
#endif  // QUEUE_H