timer_handle.hpp

// Copyright (c) 2025 [caomengxuan666]
 
#pragma once
 
#include <atomic>
#include <chrono>
#include <cstdint>
#include <functional>
#include <memory>
 
namespace mcp::core {
 
struct TimerEntry {
  std::chrono::steady_clock::time_point when;
  std::function<void()> task;
  std::atomic<bool> cancelled{false};
  std::uint64_t id = 0;
  int priority = 1;
};
 
class TimerHandle {
 public:
  TimerHandle() = default;
 
  explicit TimerHandle(std::shared_ptr<TimerEntry> entry)
      : entry_(std::move(entry)) {}
 
  bool valid() const noexcept { return entry_ != nullptr; }
 
  void cancel() {
    if (entry_) {
      entry_->cancelled.store(true, std::memory_order_release);
    }
  }
 
  bool cancelled() const noexcept {
    return !entry_ || entry_->cancelled.load(std::memory_order_acquire);
  }
 
 private:
  std::shared_ptr<TimerEntry> entry_;
};
 
}  // namespace mcp::core