ConcurrentQueue.h

Go to the documentation of this file.

#pragma once
 
 
#include "objects/wrappers/Optional.h"
#include <queue>
#include <mutex>
 
NAMESPACE_SPH_BEGIN
 
 
template <typename Type>
class ConcurrentQueue {
private:
    std::queue<Type> queue;
 
    std::mutex mutex;
 
public:
    ConcurrentQueue() = default;
 
    template <typename T>
    void push(T&& value) {
        std::unique_lock<std::mutex> lock(mutex);
        queue.push(std::forward<T>(value));
    }
 
    Optional<Type> pop() {
        std::unique_lock<std::mutex> lock(mutex);
        if (queue.empty()) {
            return NOTHING;
        }
        Type value = queue.front();
        queue.pop();
        return value;
    }
 
    bool empty() {
        std::unique_lock<std::mutex> lock(mutex);
        return queue.empty();
    }
};
 
NAMESPACE_SPH_END