ConcurrentQueue.hpp

#ifndef KINEMATICS_CONCURRENTQUEUE_HPP
#define KINEMATICS_CONCURRENTQUEUE_HPP

#include <condition_variable>
#include <mutex>
#include <queue>

namespace HLR
{
namespace Kinematics
{
template<class T>
class ConcurrentQueue
{
public:
    void push(const T& element);

    void push(T&& element);

    T pop();

    void async_pop(const std::function<void(const T&)>& handler);

    bool empty() const;

    std::size_t size() const;

private:
    std::function<void(const T&)> handler;

    std::queue<T> queue;

    mutable std::mutex queue_mutex;

    std::condition_variable notifier;
};

} // namespace Kinematics
} // namespace HLR

#include "ConcurrentQueue.ipp"

#endif