async_wait_processor.h

Go to the documentation of this file.

 
#ifndef CPPLOGGING_PROCESSORS_ASYNC_WAIT_PROCESSOR_H
#define CPPLOGGING_PROCESSORS_ASYNC_WAIT_PROCESSOR_H
 
#include "logging/processor.h"
 
#include "threads/wait_batcher.h"
 
#include <functional>
 
namespace CppLogging {
 
 
class AsyncWaitProcessor : public Processor
{
public:
 
    explicit AsyncWaitProcessor(const std::shared_ptr<Layout>& layout, bool auto_start = true, size_t capacity = 8192, size_t initial = 8192, const std::function<void ()>& on_thread_initialize = [](){}, const std::function<void ()>& on_thread_clenup = [](){});
    AsyncWaitProcessor(const AsyncWaitProcessor&) = delete;
    AsyncWaitProcessor(AsyncWaitProcessor&&) = delete;
    virtual ~AsyncWaitProcessor();
 
    AsyncWaitProcessor& operator=(const AsyncWaitProcessor&) = delete;
    AsyncWaitProcessor& operator=(AsyncWaitProcessor&&) = delete;
 
    // Implementation of Processor
    bool Start() override;
    bool Stop() override;
    bool ProcessRecord(Record& record) override;
    void Flush() override;
 
private:
    CppCommon::WaitBatcher<Record> _queue;
    std::thread _thread;
    std::function<void ()> _on_thread_initialize;
    std::function<void ()> _on_thread_clenup;
 
    bool EnqueueRecord(Record& record);
    void ProcessThread(const std::function<void ()>& on_thread_initialize, const std::function<void ()>& on_thread_clenup);
};
 
} // namespace CppLogging
 
#endif // CPPLOGGING_PROCESSORS_ASYNC_WAIT_PROCESSOR_H