logqueue.h

//   ealogger is a simple, asynchronous and powerful logger library for c++
//   Copyright 2013 - 2016 Christian Rapp
//
//   Licensed under the Apache License, Version 2.0 (the "License");
//   you may not use this file except in compliance with the License.
//   You may obtain a copy of the License at
//
//       http://www.apache.org/licenses/LICENSE-2.0
//
//   Unless required by applicable law or agreed to in writing, software
//   distributed under the License is distributed on an "AS IS" BASIS,
//   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
//   See the License for the specific language governing permissions and
//   limitations under the License.

#ifndef LOGQUEUE_H
#define LOGQUEUE_H

#include <memory>
#include <mutex>
/*
 * We use a std::queue as basis for this threadsafe queue
 */
#include <queue>
/*
 * We need a conditional variable to notify a waiting thread
 */
#include <condition_variable>

#include <ealogger/logmessage.h>

namespace ealogger
{
class LogQueue
{
public:
    LogQueue();

    void push(std::shared_ptr<LogMessage> m);
    std::shared_ptr<LogMessage> pop();
    bool empty();

private:
    std::mutex mtx;
    std::queue<std::shared_ptr<LogMessage>> msg_queue;
    std::condition_variable cond_var_queue;
};
}

#endif  // LOGQUEUE_H