C++ 实现一个定时任务执行器类-C++-PHP中文网

不能直接用std::this_thread::sleep_for做定时任务，因为它是阻塞式、串行执行的，易导致调度紊乱；可靠方案需基于steady_clock、condition_variable wait_until和最小堆实现异步、可取消、非阻塞调度。

c++ 实现一个定时任务执行器类

为什么不能直接用 `std::this_thread::sleep_for` 做定时任务

因为它是阻塞式的，一个线程只能串行执行一个任务；一旦任务耗时超预期，后续调度就全乱了。真正可用的定时器必须支持并发、可取消、不阻塞主线程——这意味着得用异步机制 + 时间轮或最小堆管理到期时间。

实际项目里，std::chrono::steady_clock 是唯一靠谱的时间源，std::condition_variable 配合 wait_until 是最轻量的等待方案，不需要引入第三方库（比如 Boost.Asio）也能落地。

别用 system_clock：它可能被系统时间调整干扰，导致任务提前或跳过
别在循环里反复 sleep_for(1ms)：CPU 白耗，精度也没提升
每个任务必须有独立的 std::atomic_bool 取消标记，否则 join() 会卡死

如何用 `std::thread` + `std::priority_queue` 实现最小堆调度

核心是把所有待执行任务按 fire_time 排序，每次只关心最近那个。C++ 没有内置可更新优先队列，所以得用 std::vector 手写 push_heap/pop_heap，或者接受“延迟删除”——插入新任务时不管旧的，执行前检查是否已取消。

下面这个结构体就是关键：

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

struct Task {
    std::function<void> fn;
    std::chrono::steady_clock::time_point fire_time;
    std::atomic_bool cancelled{false};
    bool operator>(const Task& other) const {
        return fire_time > other.fire_time; // 小顶堆
    }
};</void>

用 std::priority_queue<task std::vector>, std::greater></task> 构建最小堆
调度线程里用 cv.wait_until(lock, next_fire_time) 等待，不是忙等
每次取堆顶前先 pop 再检查 cancelled，避免执行已失效任务

`schedule_at` 和 `schedule_after` 的参数陷阱

用户传入的延迟时间，比如 5s，必须立刻转成绝对时间点（steady_clock::now() + 5s），而不是存相对值。否则如果调度线程启动慢了 2 秒，这个任务就永远晚执行 2 秒。

schedule_at 直接接收 time_point，适合对齐整点或配合外部时钟
schedule_after 接收 duration，内部必须调用 steady_clock::now() 转换，且要确保转换发生在加锁前，避免竞态
别用 std::chrono::high_resolution_clock：它在某些平台不稳，steady_clock 才是标准保证单调递增的