TokenQueue.h

Go to the documentation of this file.

/*
 * This file is part of KnowRob, please consult
 * https://github.com/knowrob/knowrob for license details.
 */
 
#ifndef KNOWROB_TOKEN_QUEUE_H_
#define KNOWROB_TOKEN_QUEUE_H_
 
#include <queue>
#include <mutex>
#include <condition_variable>
#include <knowrob/queries/TokenStream.h>
 
namespace knowrob {
    class TokenQueue : public TokenStream {
    public:
        TokenQueue();
 
        ~TokenQueue() override;
 
        TokenPtr &front();
 
        void pop();
 
        TokenPtr pop_front();
 
        bool empty() const { return queue_.empty(); }
 
        auto size() const { return queue_.size(); }
 
    protected:
        std::queue<TokenPtr> queue_;
        std::condition_variable queue_CV_;
        std::mutex queue_mutex_;
 
        // Override QueryResultStream
        void push(const TokenPtr &tok) override;
 
        void pushToQueue(const TokenPtr &tok);
    };
}
 
#endif //KNOWROB_TOKEN_QUEUE_H_