task_manager.h

Go to the documentation of this file.

// Copyright 2023 owent
 
#pragma once
 
#include <libcopp/utils/config/libcopp_build_features.h>
 
#include <libcotask/task_macros.h>
 
// clang-format off
#include <libcopp/utils/config/stl_include_prefix.h>  // NOLINT(build/include_order)
// clang-format on
#include <assert.h>
#include <stdint.h>
#include <algorithm>
#include <ctime>
#include <list>
#include <set>
#include <unordered_map>
#include <vector>
 
#ifdef __cpp_impl_three_way_comparison
#  include <compare>
#endif
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
#  include <exception>
#endif
// clang-format off
#include <libcopp/utils/config/stl_include_suffix.h>  // NOLINT(build/include_order)
// clang-format on
 
#include "libcotask/task.h"
#include "libcotask/task_promise.h"
 
LIBCOPP_COTASK_NAMESPACE_BEGIN
 
namespace detail {
struct LIBCOPP_COTASK_API_HEAD_ONLY tickspec_t {
  time_t tv_sec; /* Seconds.  */
  int tv_nsec;   /* Nanoseconds.  */
 
  inline friend bool operator==(const tickspec_t &l, const tickspec_t &r) {
    return l.tv_sec == r.tv_sec && l.tv_nsec == r.tv_nsec;
  }
 
#ifdef __cpp_impl_three_way_comparison
  inline friend std::strong_ordering operator<=>(const tickspec_t &l, const tickspec_t &r) {
    return (l.tv_sec != r.tv_sec) ? l.tv_sec <=> r.tv_sec : l.tv_nsec <=> r.tv_nsec;
  }
#else
  inline friend bool operator!=(const tickspec_t &l, const tickspec_t &r) {
    return l.tv_sec != r.tv_sec || l.tv_nsec != r.tv_nsec;
  }
 
  inline friend bool operator<(const tickspec_t &l, const tickspec_t &r) {
    return (l.tv_sec != r.tv_sec) ? l.tv_sec < r.tv_sec : l.tv_nsec < r.tv_nsec;
  }
 
  inline friend bool operator<=(const tickspec_t &l, const tickspec_t &r) {
    return (l.tv_sec != r.tv_sec) ? l.tv_sec <= r.tv_sec : l.tv_nsec <= r.tv_nsec;
  }
 
  inline friend bool operator>(const tickspec_t &l, const tickspec_t &r) {
    return (l.tv_sec != r.tv_sec) ? l.tv_sec > r.tv_sec : l.tv_nsec > r.tv_nsec;
  }
 
  inline friend bool operator>=(const tickspec_t &l, const tickspec_t &r) {
    return (l.tv_sec != r.tv_sec) ? l.tv_sec >= r.tv_sec : l.tv_nsec >= r.tv_nsec;
  }
#endif
};
 
template <class TTASK_ID_TYPE>
struct LIBCOPP_COTASK_API_HEAD_ONLY task_timer_node {
  tickspec_t expired_time;
  TTASK_ID_TYPE task_id;
 
  inline friend bool operator==(const task_timer_node &l, const task_timer_node &r) {
    return l.expired_time == r.expired_time && l.task_id == r.task_id;
  }
 
#ifdef __cpp_impl_three_way_comparison
  inline friend std::strong_ordering operator<=>(const task_timer_node &l, const task_timer_node &r) {
    if (l.expired_time != r.expired_time) {
      return l.expired_time <=> r.expired_time;
    }
 
    return l.task_id <=> r.task_id;
  }
#else
  inline friend bool operator!=(const task_timer_node &l, const task_timer_node &r) {
    return l.expired_time != r.expired_time || l.task_id != r.task_id;
  }
 
  inline friend bool operator<(const task_timer_node &l, const task_timer_node &r) {
    if (l.expired_time != r.expired_time) {
      return l.expired_time < r.expired_time;
    }
 
    return l.task_id < r.task_id;
  }
 
  inline friend bool operator<=(const task_timer_node &l, const task_timer_node &r) {
    if (l.expired_time != r.expired_time) {
      return l.expired_time <= r.expired_time;
    }
 
    return l.task_id <= r.task_id;
  }
 
  inline friend bool operator>(const task_timer_node &l, const task_timer_node &r) {
    if (l.expired_time != r.expired_time) {
      return l.expired_time > r.expired_time;
    }
 
    return l.task_id > r.task_id;
  }
 
  inline friend bool operator>=(const task_timer_node &l, const task_timer_node &r) {
    if (l.expired_time != r.expired_time) {
      return l.expired_time >= r.expired_time;
    }
 
    return l.task_id >= r.task_id;
  }
#endif
};
 
template <class TTask>
struct LIBCOPP_COTASK_API_HEAD_ONLY task_manager_node;
 
template <class TCO_MACRO>
struct LIBCOPP_COTASK_API_HEAD_ONLY task_manager_node<task<TCO_MACRO>> {
  using task_ptr_type = typename task<TCO_MACRO>::ptr_type;
 
  task_ptr_type task_;
  typename std::set<task_timer_node<typename task<TCO_MACRO>::id_type>>::iterator timer_node;
};
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_COROUTINE) && LIBCOPP_MACRO_ENABLE_STD_COROUTINE
template <class TVALUE, class TPRIVATE_DATA, class TERROR_TRANSFORM>
struct LIBCOPP_COTASK_API_HEAD_ONLY task_manager_node<task_future<TVALUE, TPRIVATE_DATA, TERROR_TRANSFORM>> {
  using task_type = task_future<TVALUE, TPRIVATE_DATA, TERROR_TRANSFORM>;
 
  task_type task_;
  typename std::set<task_timer_node<typename task_type::id_type>>::iterator timer_node;
};
#endif
 
}  // namespace detail
 
template <typename TTask>
class LIBCOPP_COTASK_API_HEAD_ONLY task_manager;
 
template <typename TCO_MACRO>
class LIBCOPP_COTASK_API_HEAD_ONLY task_manager<task<TCO_MACRO>> {
 public:
  using task_type = task<TCO_MACRO>;
  using container_type = std::unordered_map<typename task_type::id_type, detail::task_manager_node<task_type>>;
  using id_type = typename task_type::id_type;
  using task_ptr_type = typename task_type::ptr_type;
  using self_type = task_manager<task_type>;
  using ptr_type = std::shared_ptr<self_type>;
 
  struct flag_type {
    enum type {
      EN_TM_NONE = 0x00,
      EN_TM_IN_TICK = 0x01,
      EN_TM_IN_RESET = 0x02,
    };
  };
 
  // Compability with libcopp-1.x
  using id_t = id_type;
  using self_t = self_type;
  using task_t = task_type;
  using task_ptr_t = task_ptr_type;
  using ptr_t = ptr_type;
  using container_t = container_type;
  using flag_t = flag_type;
 
 private:
  struct flag_guard_type {
    int *data_;
    typename flag_type::type flag_;
    inline flag_guard_type(int *flags, typename flag_type::type v) : data_(flags), flag_(v) {
      if (nullptr == data_ || (*data_ & flag_)) {
        flag_ = flag_type::EN_TM_NONE;
        data_ = nullptr;
      } else {
        (*data_) |= flag_;
      }
    }
    inline ~flag_guard_type() {
      if (*this) {
        (*data_) &= ~flag_;
      }
    }
 
    inline operator bool() { return nullptr != data_ && flag_type::EN_TM_NONE != flag_; }
  };
 
 public:
  task_manager() : flags_(0) {
    last_tick_time_.tv_sec = 0;
    last_tick_time_.tv_nsec = 0;
  }
 
  ~task_manager() {
    // safe remove all task
    reset();
  }
 
  void reset() {
    flag_guard_type reset_flag(&flags_, flag_type::EN_TM_IN_RESET);
    if (!reset_flag) {
      return;
    }
 
    std::vector<task_ptr_type> all_tasks;
    // first, lock and reset all data
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      for (typename container_type::iterator iter = tasks_.begin(); iter != tasks_.end(); ++iter) {
        all_tasks.push_back(iter->second.task_);
        remove_timeout_timer(iter->second);
      }
 
      tasks_.clear();
      task_timeout_timer_.clear();
      flags_ = 0;
      last_tick_time_.tv_sec = 0;
      last_tick_time_.tv_nsec = 0;
    }
 
    // then, kill all tasks
    for (typename std::vector<task_ptr_type>::iterator iter = all_tasks.begin(); iter != all_tasks.end(); ++iter) {
      if (!(*iter)->is_exiting()) {
        (*iter)->kill(EN_TS_KILLED);
      }
    }
  }
 
  static ptr_type create() { return std::make_shared<self_type>(); }
 
  int add_task(const task_ptr_type &task, time_t timeout_sec, int timeout_nsec) {
    if (!task) {
      assert(task);
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_ARGS_ERROR;
    }
 
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    if (task->is_exiting()) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_TASK_IS_EXITING;
    }
 
    // try to cast type
    using pair_type = typename container_type::value_type;
    detail::task_manager_node<task_type> task_node;
    task_node.task_ = task;
    task_node.timer_node = task_timeout_timer_.end();
 
    if (!task_node.task_) {
      assert(task_node.task_);
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_CAST_FAILED;
    }
 
    // lock before we will operator tasks_
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
    LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
        action_lock_};
#endif
 
    id_type task_id = task->get_id();
    if (tasks_.end() != tasks_.find(task_id)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_ALREADY_EXIST;
    }
 
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
    using task_manager_helper = typename task_type::task_manager_helper;
    if (!task_manager_helper::setup_task_manager(*task, reinterpret_cast<void *>(this), &task_cleanup_callback)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_TASK_ALREADY_IN_ANOTHER_MANAGER;
    }
#endif
 
    // try to insert to container
    std::pair<typename container_type::iterator, bool> res = tasks_.insert(pair_type(task_id, task_node));
    if (false == res.second) {
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      task_manager_helper::cleanup_task_manager(*task, reinterpret_cast<void *>(this));
#endif
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_EXTERNAL_INSERT_FAILED;
    }
 
    // add timeout controller
    set_timeout_timer(res.first->second, timeout_sec, timeout_nsec);
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  int add_task(const task_ptr_type &task) { return add_task(task, 0, 0); }
 
  int set_timeout(id_type id, time_t timeout_sec, int timeout_nsec) {
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
 
      set_timeout_timer(iter->second, timeout_sec, timeout_nsec);
    }
 
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  inline int remove_task(id_type id, const task_ptr_type &confirm_ptr) { return remove_task(id, confirm_ptr.get()); }
 
  inline int remove_task(id_type id) { return remove_task(id, nullptr); }
 
  int remove_task(id_type id, const task_type *confirm_ptr) {
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_ptr_type task_inst;
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
      if (nullptr != confirm_ptr && iter->second.task_.get() != confirm_ptr) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
 
      // make sure running task be killed first
      task_inst = std::move(iter->second.task_);
 
      remove_timeout_timer(iter->second);
      tasks_.erase(iter);
    }
 
    if (task_inst) {
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      using task_manager_helper = typename task_type::task_manager_helper;
      // already cleanup, there is no need to cleanup again
      task_manager_helper::cleanup_task_manager(*task_inst, reinterpret_cast<void *>(this));
#endif
 
      EN_TASK_STATUS task_status = task_inst->get_status();
      if (task_status > EN_TS_CREATED && task_status < EN_TS_DONE) {
        return task_inst->kill(EN_TS_KILLED, nullptr);
      }
    }
 
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  task_ptr_type find_task(id_type id) {
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return task_ptr_type();
    }
 
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
    LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
        action_lock_};
#endif
 
    using iter_type = typename container_type::iterator;
    iter_type iter = tasks_.find(id);
    if (tasks_.end() == iter) return task_ptr_type();
 
    return iter->second.task_;
  }
 
  // int add_scheduler();
  // int scheduling_once();
  // int scheduling_loop();
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
  int start(id_type id, void *priv_data = nullptr) {
    std::list<std::exception_ptr> eptrs;
    int ret = start(id, eptrs, priv_data);
    task_type::maybe_rethrow(eptrs);
    return ret;
  }
 
  int start(id_type id, std::list<std::exception_ptr> &unhandled, void *priv_data = nullptr) LIBCOPP_MACRO_NOEXCEPT {
#else
  int start(id_type id, void *priv_data = nullptr) {
#endif
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_ptr_type task_inst;
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
 
      task_inst = iter->second.task_;
    }
 
    // unlock and then run start
    if (task_inst) {
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
      int ret = task_inst->start(unhandled, priv_data);
#else
      int ret = task_inst->start(priv_data);
#endif
 
      // if task is finished, remove it
      if (task_inst->get_status() >= EN_TS_DONE) {
        remove_task(id);
      }
 
      return ret;
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
  int resume(id_type id, void *priv_data = nullptr) {
    std::list<std::exception_ptr> eptrs;
    int ret = resume(id, eptrs, priv_data);
    task_type::maybe_rethrow(eptrs);
    return ret;
  }
 
  int resume(id_type id, std::list<std::exception_ptr> &unhandled, void *priv_data = nullptr) LIBCOPP_MACRO_NOEXCEPT {
#else
  int resume(id_type id, void *priv_data = nullptr) {
#endif
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_ptr_type task_inst;
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
 
      task_inst = iter->second.task_;
    }
 
    // unlock and then run resume
    if (task_inst) {
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
      int ret = task_inst->resume(unhandled, priv_data);
#else
      int ret = task_inst->resume(priv_data);
#endif
 
      // if task is finished, remove it
      if (task_inst->get_status() >= EN_TS_DONE) {
        remove_task(id);
      }
 
      return ret;
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
  int cancel(id_type id, void *priv_data = nullptr) {
    std::list<std::exception_ptr> eptrs;
    int ret = cancel(id, eptrs, priv_data);
    task_type::maybe_rethrow(eptrs);
    return ret;
  }
 
  int cancel(id_type id, std::list<std::exception_ptr> &unhandled, void *priv_data = nullptr) LIBCOPP_MACRO_NOEXCEPT {
#else
  int cancel(id_type id, void *priv_data = nullptr) {
#endif
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_ptr_type task_inst;
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
 
      task_inst = std::move(iter->second.task_);
 
      remove_timeout_timer(iter->second);
      tasks_.erase(iter);  // remove from container
    }
 
    // unlock and then run cancel
    if (task_inst) {
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      using task_manager_helper = typename task_type::task_manager_helper;
      // already cleanup, there is no need to cleanup again
      task_manager_helper::cleanup_task_manager(*task_inst, reinterpret_cast<void *>(this));
#endif
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
      return task_inst->cancel(unhandled, priv_data);
#else
      return task_inst->cancel(priv_data);
#endif
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
  int kill(id_type id, enum EN_TASK_STATUS status, void *priv_data = nullptr) {
    std::list<std::exception_ptr> eptrs;
    int ret = kill(id, eptrs, status, priv_data);
    task_type::maybe_rethrow(eptrs);
    return ret;
  }
 
  int kill(id_type id, std::list<std::exception_ptr> &unhandled, enum EN_TASK_STATUS status,
           void *priv_data = nullptr) LIBCOPP_MACRO_NOEXCEPT {
#else
  int kill(id_type id, enum EN_TASK_STATUS status, void *priv_data = nullptr) {
#endif
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_ptr_type task_inst;
    {
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
 
      task_inst = std::move(iter->second.task_);
 
      remove_timeout_timer(iter->second);
      tasks_.erase(iter);  // remove from container
    }
 
    // unlock and then run kill
    if (task_inst) {
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      using task_manager_helper = typename task_type::task_manager_helper;
      // already cleanup, there is no need to cleanup again
      task_manager_helper::cleanup_task_manager(*task_inst, reinterpret_cast<void *>(this));
#endif
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
      return task_inst->kill(unhandled, status, priv_data);
#else
      return task_inst->kill(status, priv_data);
#endif
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
  int kill(id_type id, void *priv_data = nullptr) { return kill(id, EN_TS_KILLED, priv_data); }
 
  int tick(time_t sec, int nsec = 0) {
    detail::tickspec_t now_tick_time;
    // time can not be back
    if (sec < last_tick_time_.tv_sec || (sec == last_tick_time_.tv_sec && nsec <= last_tick_time_.tv_nsec)) {
      return 0;
    }
 
    now_tick_time.tv_sec = sec;
    now_tick_time.tv_nsec = nsec;
 
    // we will ignore tick when in a recursive call
    flag_guard_type tick_flag(&flags_, flag_type::EN_TM_IN_TICK);
    if (!tick_flag) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    }
 
    if (flags_ & flag_type::EN_TM_IN_RESET) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    // first tick, init and reset task timeout
    if (0 == last_tick_time_.tv_sec && 0 == last_tick_time_.tv_nsec) {
      // hold lock
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#endif
 
      std::set<detail::task_timer_node<id_type>> real_checkpoints;
      for (typename std::set<detail::task_timer_node<id_type>>::iterator iter = task_timeout_timer_.begin();
           task_timeout_timer_.end() != iter; ++iter) {
        detail::task_timer_node<id_type> new_checkpoint = (*iter);
        new_checkpoint.expired_time.tv_sec += sec;
        new_checkpoint.expired_time.tv_nsec += nsec;
        real_checkpoints.insert(new_checkpoint);
      }
 
      task_timeout_timer_.swap(real_checkpoints);
      for (typename std::set<detail::task_timer_node<id_type>>::iterator iter = task_timeout_timer_.begin();
           task_timeout_timer_.end() != iter; ++iter) {
        const typename std::set<detail::task_timer_node<id_type>>::value_type &checkpoint = *iter;
        using co_iter_type = typename container_type::iterator;
        co_iter_type  co_iter = tasks_.find(checkpoint.task_id);
 
        if (tasks_.end() != co_iter) {
          co_iter->second.timer_node = iter;
        }
      }
      last_tick_time_ = now_tick_time;
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    }
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
    std::list<std::exception_ptr> eptrs;
#endif
    // remove timeout tasks
    while (false == task_timeout_timer_.empty()) {
      task_ptr_type task_inst;
 
      {
        // hold lock
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
        LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
            action_lock_};
#endif
 
        const typename std::set<detail::task_timer_node<id_type>>::value_type &timer_node =
            *task_timeout_timer_.begin();
        // all tasks those expired time less than now are timeout
        if (now_tick_time <= timer_node.expired_time) {
          break;
        }
 
        // check expire time(may be changed)
        using iter_type = typename container_type::iterator;
 
        iter_type iter = tasks_.find(timer_node.task_id);
 
        if (tasks_.end() != iter) {
          // task may be removed before
          task_inst = std::move(iter->second.task_);
 
          remove_timeout_timer(iter->second);
          tasks_.erase(iter);  // remove from container
        }
      }
 
      // task call can not be used when lock is on
      if (task_inst && !task_inst->is_exiting()) {
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
        using task_manager_helper = typename task_type::task_manager_helper;
        // already cleanup, there is no need to cleanup again
        task_manager_helper::cleanup_task_manager(*task_inst, reinterpret_cast<void *>(this));
#endif
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
        task_inst->kill(eptrs, EN_TS_TIMEOUT, nullptr);
#else
        task_inst->kill(EN_TS_TIMEOUT);
#endif
      }
    }
 
    last_tick_time_ = now_tick_time;
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR) && LIBCOPP_MACRO_ENABLE_STD_EXCEPTION_PTR
    task_type::maybe_rethrow(eptrs);
#endif
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  size_t get_tick_checkpoint_size() const LIBCOPP_MACRO_NOEXCEPT { return task_timeout_timer_.size(); }
 
  size_t get_task_size() const LIBCOPP_MACRO_NOEXCEPT { return tasks_.size(); }
 
  detail::tickspec_t get_last_tick_time() const LIBCOPP_MACRO_NOEXCEPT { return last_tick_time_; }
 
  inline const container_type &get_container() const LIBCOPP_MACRO_NOEXCEPT { return tasks_; }
 
  inline const std::set<detail::task_timer_node<id_type>> &get_checkpoints() const LIBCOPP_MACRO_NOEXCEPT {
    return task_timeout_timer_;
  }
 
 private:
  void set_timeout_timer(detail::task_manager_node<task_type> &node, time_t timeout_sec, int timeout_nsec) {
    remove_timeout_timer(node);
 
    if (timeout_sec <= 0 && timeout_nsec <= 0) {
      return;
    }
 
    if (!node.task_) {
      return;
    }
 
    detail::task_timer_node<id_type> timer_node;
    timer_node.task_id = node.task_->get_id();
    timer_node.expired_time.tv_sec = last_tick_time_.tv_sec + timeout_sec;
    timer_node.expired_time.tv_nsec = last_tick_time_.tv_nsec + timeout_nsec;
 
    std::pair<typename std::set<detail::task_timer_node<id_type>>::iterator, bool> res =
        task_timeout_timer_.insert(timer_node);
    if (res.second) {
      node.timer_node = res.first;
    }
  }
 
  void remove_timeout_timer(detail::task_manager_node<task_type> &node) {
    if (node.timer_node != task_timeout_timer_.end()) {
      task_timeout_timer_.erase(node.timer_node);
      node.timer_node = task_timeout_timer_.end();
    }
  }
 
#if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
  static void task_cleanup_callback(void *self_ptr, task_type &task_inst) {
    if (nullptr == self_ptr) {
      return;
    }
 
    reinterpret_cast<self_type *>(self_ptr)->remove_task(task_inst.get_id(), &task_inst);
  }
#endif
 
 private:
  container_type tasks_;
  detail::tickspec_t last_tick_time_;
  std::set<detail::task_timer_node<id_type>> task_timeout_timer_;
 
#if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
  LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock action_lock_;
#endif
  int flags_;
};
 
#if defined(LIBCOPP_MACRO_ENABLE_STD_COROUTINE) && LIBCOPP_MACRO_ENABLE_STD_COROUTINE
template <class TVALUE, class TPRIVATE_DATA, class TERROR_TRANSFORM>
class LIBCOPP_COTASK_API_HEAD_ONLY task_manager<task_future<TVALUE, TPRIVATE_DATA, TERROR_TRANSFORM>> {
 public:
  using task_type = task_future<TVALUE, TPRIVATE_DATA, TERROR_TRANSFORM>;
  using container_type = std::unordered_map<typename task_type::id_type, detail::task_manager_node<task_type>>;
  using id_type = typename task_type::id_type;
  using task_status_type = typename task_type::task_status_type;
  using self_type = task_manager<task_type>;
  using ptr_type = std::shared_ptr<self_type>;
 
  enum class flag_type : uint32_t{
      kNone = 0,
      kTimerTick = 0x01,
      kTimerReset = 0x02,
  };
 
 private:
  struct flag_guard_type {
    uint32_t *data_;
    flag_type flag_;
    inline flag_guard_type(uint32_t *flags, flag_type v) : data_(flags), flag_(v) {
      if (nullptr == data_ || (*data_ & static_cast<uint32_t>(flag_))) {
        flag_ = flag_type::kNone;
        data_ = nullptr;
      } else {
        (*data_) |= static_cast<uint32_t>(flag_);
      }
    }
    inline ~flag_guard_type() {
      if (*this) {
        (*data_) &= ~static_cast<uint32_t>(flag_);
      }
    }
 
    inline operator bool() { return nullptr != data_ && flag_type::kNone != flag_; }
  };
 
 public:
  task_manager() : flags_(0) {
    last_tick_time_.tv_sec = 0;
    last_tick_time_.tv_nsec = 0;
  }
 
  ~task_manager() {
    // safe remove all task
    reset();
  }
 
  void reset() {
    flag_guard_type reset_flag(&flags_, flag_type::kTimerReset);
    if (!reset_flag) {
      return;
    }
 
    std::vector<task_type> all_tasks;
    // first, lock and reset all data
    {
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      for (typename container_type::iterator iter = tasks_.begin(); iter != tasks_.end(); ++iter) {
        all_tasks.push_back(iter->second.task_);
        remove_timeout_timer(iter->second);
      }
 
      tasks_.clear();
      task_timeout_timer_.clear();
      flags_ = 0;
      last_tick_time_.tv_sec = 0;
      last_tick_time_.tv_nsec = 0;
    }
 
    // then, kill all tasks
    for (typename std::vector<task_type>::iterator iter = all_tasks.begin(); iter != all_tasks.end(); ++iter) {
      if (!(*iter).is_exiting()) {
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
        using task_manager_helper = typename task_type::task_manager_helper;
        // already cleanup, there is no need to cleanup again
        task_manager_helper::cleanup_task_manager(*(*iter).get_context(), reinterpret_cast<void *>(this));
#  endif
 
        (*iter).kill(task_status_type::kKilled);
      }
    }
  }
 
  static ptr_type create() noexcept { return std::make_shared<self_type>(); }
 
  int add_task(const task_type &task, time_t timeout_sec, int timeout_nsec) noexcept {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    if (task.is_exiting()) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_TASK_IS_EXITING;
    }
 
    // try to cast type
    using pair_type = typename container_type::value_type;
    detail::task_manager_node<task_type> task_node;
    task_node.task_ = task;
    task_node.timer_node = task_timeout_timer_.end();
 
    // lock before we will operator tasks_
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
    LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
        action_lock_};
#  endif
 
    id_type task_id = task.get_id();
    if (tasks_.end() != tasks_.find(task_id)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_ALREADY_EXIST;
    }
 
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
    using task_manager_helper = typename task_type::task_manager_helper;
    if (!task_manager_helper::setup_task_manager(*task.get_context(), reinterpret_cast<void *>(this),
                                                 &task_cleanup_callback)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_TASK_ALREADY_IN_ANOTHER_MANAGER;
    }
#  endif
 
    // try to insert to container
    std::pair<typename container_type::iterator, bool> res = tasks_.insert(pair_type(task_id, task_node));
    if (false == res.second) {
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      task_manager_helper::cleanup_task_manager(*task.get_context(), reinterpret_cast<void *>(this));
#  endif
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_EXTERNAL_INSERT_FAILED;
    }
 
    // add timeout controller
    set_timeout_timer(res.first->second, timeout_sec, timeout_nsec);
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  int add_task(const task_type &task) noexcept { return add_task(task, 0, 0); }
 
  int set_timeout(id_type id, time_t timeout_sec, int timeout_nsec) noexcept {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    {
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
 
      set_timeout_timer(iter->second, timeout_sec, timeout_nsec);
    }
 
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  inline int remove_task(id_type id, const task_type &confirm_task) {
    return remove_task(id, confirm_task.get_context().get());
  }
 
  inline int remove_task(id_type id) { return remove_task(id, nullptr); }
 
  int remove_task(id_type id, const task_context_base<TVALUE> *confirm_context) {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_type task_inst;
    {
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
      if (nullptr != confirm_context && iter->second.task_.get_context().get() != confirm_context) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
 
      // make sure running task be killed first
      task_inst = std::move(iter->second.task_);
 
      remove_timeout_timer(iter->second);
      tasks_.erase(iter);
    }
 
    if (task_inst.get_context()) {
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      using task_manager_helper = typename task_type::task_manager_helper;
      // already cleanup, there is no need to cleanup again
      task_manager_helper::cleanup_task_manager(*task_inst.get_context(), reinterpret_cast<void *>(this));
#  endif
 
      task_status_type task_status = task_inst.get_status();
      if (task_status > task_status_type::kCreated && task_status < task_status_type::kDone) {
        return task_inst.kill(task_status_type::kKilled);
      }
    }
 
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  const task_type *find_task(id_type id) noexcept {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return nullptr;
    }
 
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
    LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
        action_lock_};
#  endif
 
    auto iter = tasks_.find(id);
    if (tasks_.end() == iter) {
      return nullptr;
    }
 
    return &iter->second.task_;
  }
 
  int start(id_type id) {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_type task_inst;
    {
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
 
      task_inst = iter->second.task_;
    }
 
    // unlock and then run start
    if (task_inst.get_context()) {
      task_inst.start();
 
      // if task is finished, remove it
      if (task_inst.is_exiting()) {
        remove_task(id, task_inst);
      }
 
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
  int cancel(id_type id) {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_type task_inst;
    {
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
 
      task_inst = std::move(iter->second.task_);
 
      remove_timeout_timer(iter->second);
      tasks_.erase(iter);  // remove from container
    }
 
    // unlock and then run cancel
    if (task_inst.get_context()) {
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      using task_manager_helper = typename task_type::task_manager_helper;
      // already cleanup, there is no need to cleanup again
      task_manager_helper::cleanup_task_manager(*task_inst.get_context(), reinterpret_cast<void *>(this));
#  endif
      task_inst.cancel();
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
  int kill(id_type id, task_status_type target_status) {
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    task_type task_inst;
    {
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      using iter_type = typename container_type::iterator;
      iter_type iter = tasks_.find(id);
      if (tasks_.end() == iter) {
        return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
      }
 
      task_inst = std::move(iter->second.task_);
 
      remove_timeout_timer(iter->second);
      tasks_.erase(iter);  // remove from container
    }
 
    // unlock and then run kill
    if (task_inst.get_context()) {
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
      using task_manager_helper = typename task_type::task_manager_helper;
      // already cleanup, there is no need to cleanup again
      task_manager_helper::cleanup_task_manager(*task_inst.get_context(), reinterpret_cast<void *>(this));
#  endif
      task_inst.kill(target_status);
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    } else {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_NOT_FOUND;
    }
  }
 
  int kill(id_type id) { return kill(id, task_status_type::kKilled); }
 
  int tick(time_t sec, int nsec = 0) {
    detail::tickspec_t now_tick_time;
    // time can not be back
    if (sec < last_tick_time_.tv_sec || (sec == last_tick_time_.tv_sec && nsec <= last_tick_time_.tv_nsec)) {
      return 0;
    }
 
    now_tick_time.tv_sec = sec;
    now_tick_time.tv_nsec = nsec;
 
    // we will ignore tick when in a recursive call
    flag_guard_type tick_flag(&flags_, flag_type::kTimerTick);
    if (!tick_flag) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    }
 
    if (flags_ & static_cast<uint32_t>(flag_type::kTimerReset)) {
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_IN_RESET;
    }
 
    // first tick, init and reset task timeout
    if (0 == last_tick_time_.tv_sec && 0 == last_tick_time_.tv_nsec) {
      // hold lock
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
      LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
          action_lock_};
#  endif
 
      std::set<detail::task_timer_node<id_type>> real_checkpoints;
      for (typename std::set<detail::task_timer_node<id_type>>::iterator iter = task_timeout_timer_.begin();
           task_timeout_timer_.end() != iter; ++iter) {
        detail::task_timer_node<id_type> new_checkpoint = (*iter);
        new_checkpoint.expired_time.tv_sec += sec;
        new_checkpoint.expired_time.tv_nsec += nsec;
        real_checkpoints.insert(new_checkpoint);
      }
 
      task_timeout_timer_.swap(real_checkpoints);
      for (typename std::set<detail::task_timer_node<id_type>>::iterator iter = task_timeout_timer_.begin();
           task_timeout_timer_.end() != iter; ++iter) {
        const typename std::set<detail::task_timer_node<id_type>>::value_type &checkpoint = *iter;
        using co_iter_type = typename container_type::iterator;
        co_iter_type  co_iter = tasks_.find(checkpoint.task_id);
 
        if (tasks_.end() != co_iter) {
          co_iter->second.timer_node = iter;
        }
      }
      last_tick_time_ = now_tick_time;
      return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
    }
 
    // remove timeout tasks
    while (false == task_timeout_timer_.empty()) {
      task_type task_inst;
 
      {
        // hold lock
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
        LIBCOPP_COPP_NAMESPACE_ID::util::lock::lock_holder<LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock> lock_guard{
            action_lock_};
#  endif
 
        const typename std::set<detail::task_timer_node<id_type>>::value_type &timer_node =
            *task_timeout_timer_.begin();
        // all tasks those expired time less than now are timeout
        if (now_tick_time <= timer_node.expired_time) {
          break;
        }
 
        // check expire time(may be changed)
        using iter_type = typename container_type::iterator;
 
        iter_type iter = tasks_.find(timer_node.task_id);
 
        if (tasks_.end() != iter) {
          // task may be removed before
          task_inst = std::move(iter->second.task_);
 
          remove_timeout_timer(iter->second);
          tasks_.erase(iter);  // remove from container
        }
      }
 
      // task call can not be used when lock is on
      if (!task_inst.is_exiting()) {
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
        using task_manager_helper = typename task_type::task_manager_helper;
        // already cleanup, there is no need to cleanup again
        task_manager_helper::cleanup_task_manager(*task_inst.get_context(), reinterpret_cast<void *>(this));
#  endif
        task_inst.kill(task_status_type::kTimeout);
      }
    }
 
    last_tick_time_ = now_tick_time;
    return LIBCOPP_COPP_NAMESPACE_ID::COPP_EC_SUCCESS;
  }
 
  size_t get_tick_checkpoint_size() const LIBCOPP_MACRO_NOEXCEPT { return task_timeout_timer_.size(); }
 
  size_t get_task_size() const LIBCOPP_MACRO_NOEXCEPT { return tasks_.size(); }
 
  detail::tickspec_t get_last_tick_time() const LIBCOPP_MACRO_NOEXCEPT { return last_tick_time_; }
 
  inline const container_type &get_container() const LIBCOPP_MACRO_NOEXCEPT { return tasks_; }
 
  inline const std::set<detail::task_timer_node<id_type>> &get_checkpoints() const LIBCOPP_MACRO_NOEXCEPT {
    return task_timeout_timer_;
  }
 
 private:
  void set_timeout_timer(detail::task_manager_node<task_type> &node, time_t timeout_sec, int timeout_nsec) {
    remove_timeout_timer(node);
 
    if (timeout_sec <= 0 && timeout_nsec <= 0) {
      return;
    }
 
    if (!node.task_.get_context()) {
      return;
    }
 
    detail::task_timer_node<id_type> timer_node;
    timer_node.task_id = node.task_.get_id();
    timer_node.expired_time.tv_sec = last_tick_time_.tv_sec + timeout_sec;
    timer_node.expired_time.tv_nsec = last_tick_time_.tv_nsec + timeout_nsec;
 
    std::pair<typename std::set<detail::task_timer_node<id_type>>::iterator, bool> res =
        task_timeout_timer_.insert(timer_node);
    if (res.second) {
      node.timer_node = res.first;
    }
  }
 
  void remove_timeout_timer(detail::task_manager_node<task_type> &node) {
    if (node.timer_node != task_timeout_timer_.end()) {
      task_timeout_timer_.erase(node.timer_node);
      node.timer_node = task_timeout_timer_.end();
    }
  }
 
#  if defined(LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER) && LIBCOTASK_MACRO_AUTO_CLEANUP_MANAGER
  static void task_cleanup_callback(void *self_ptr, task_context_base<TVALUE> &task_inst) {
    if (nullptr == self_ptr) {
      return;
    }
 
    reinterpret_cast<self_type *>(self_ptr)->remove_task(task_inst.get_id(), &task_inst);
  }
#  endif
 
 private:
  container_type tasks_;
  detail::tickspec_t last_tick_time_;
  std::set<detail::task_timer_node<id_type>> task_timeout_timer_;
 
#  if !defined(LIBCOPP_DISABLE_ATOMIC_LOCK) || !(LIBCOPP_DISABLE_ATOMIC_LOCK)
  LIBCOPP_COPP_NAMESPACE_ID::util::lock::spin_lock action_lock_;
#  endif
  uint32_t flags_;
};
#endif
 
LIBCOPP_COTASK_NAMESPACE_END