TaskRunnerGetter.h

 
#pragma once
 
#include <mutex>
 
#include "core/GpgFrontendCore.h"
#include "core/function/basic/GpgFunctionObject.h"
#include "core/thread/TaskRunner.h"
 
namespace GpgFrontend::Thread {
 
using TaskRunnerPtr = std::shared_ptr<TaskRunner>;
 
class GPGFRONTEND_CORE_EXPORT TaskRunnerGetter
    : public GpgFrontend::SingletonFunctionObject<TaskRunnerGetter> {
 public:
  enum TaskRunnerType {
    kTaskRunnerType_Default,
    kTaskRunnerType_GPG,
    kTaskRunnerType_IO,
    kTaskRunnerType_Network,
    kTaskRunnerType_Module,
    kTaskRunnerType_External_Process,
  };
 
  explicit TaskRunnerGetter(
      int channel = SingletonFunctionObject::GetDefaultChannel());
 
  auto GetTaskRunner(TaskRunnerType runner_type = kTaskRunnerType_Default)
      -> TaskRunnerPtr;
 
  void StopAllTeakRunner();
 
 private:
  std::map<TaskRunnerType, TaskRunnerPtr> task_runners_;
  std::mutex task_runners_map_lock_;
};
 
}  // namespace GpgFrontend::Thread