DelayExecutor.h

Go to the documentation of this file.

/*
* This file is part of Project SkyFire https://www.projectskyfire.org.
* See LICENSE.md file for Copyright information
*/
 
#ifndef _M_DELAY_EXECUTOR_H
#define _M_DELAY_EXECUTOR_H
 
#include "Define.h"
 
#include <memory>
 
class DelayTask
{
public:
    virtual ~DelayTask() { }
    virtual int call() = 0;
};
 
struct DelayExecutorMetricsSnapshot
{
    DelayExecutorMetricsSnapshot()
        : Submitted(0), Completed(0), Rejected(0), Backlog(0), BacklogHighWater(0), BacklogHighWaterEvents(0) { }
 
    uint64 Submitted;
    uint64 Completed;
    uint64 Rejected;
    uint32 Backlog;
    uint32 BacklogHighWater;
    uint64 BacklogHighWaterEvents;
};
 
class DelayExecutor
{
public:
    DelayExecutor();
    virtual ~DelayExecutor();
    static DelayExecutor* instance();
    int execute(std::unique_ptr<DelayTask> new_req);
    int start(int num_threads = 1, std::unique_ptr<DelayTask> pre_svc_hook = std::unique_ptr<DelayTask>(), std::unique_ptr<DelayTask> post_svc_hook = std::unique_ptr<DelayTask>());
    int deactivate();
    bool activated();
    int svc();
    DelayExecutorMetricsSnapshot GetMetricsSnapshot() const;
    void ResetMetrics();
 
private:
    struct Impl;
 
    std::unique_ptr<Impl> impl_;
 
    void activated(bool s);
};
 
#endif // _M_DELAY_EXECUTOR_H