SerialTaskQueue.h

 
#pragma once
 
#include "TaskQueue.h"
#include <trantor/net/EventLoopThread.h>
#include <trantor/exports.h>
#include <string>
#include <queue>
#include <mutex>
#include <atomic>
namespace trantor
{
class TRANTOR_EXPORT SerialTaskQueue : public TaskQueue
{
  public:
    virtual void runTaskInQueue(const std::function<void()> &task);
    virtual void runTaskInQueue(std::function<void()> &&task);

    virtual std::string getName() const
    {
        return queueName_;
    };

    void waitAllTasksFinished();
 
    SerialTaskQueue() = delete;

    explicit SerialTaskQueue(const std::string &name);
 
    virtual ~SerialTaskQueue();
 
    /* clang-format off */
    [[deprecated("Use isRunningTask instead")]]
    bool isRuningTask()
    {
        return isRunningTask();
    }
    /* clang-format on */

    bool isRunningTask()
    {
        return loopThread_.getLoop()
                   ? loopThread_.getLoop()->isCallingFunctions()
                   : false;
    }

    size_t getTaskCount();

    void stop();
 
  protected:
    std::string queueName_;
    EventLoopThread loopThread_;
    bool stop_{false};
};
}  // namespace trantor