Python sched.scheduler 怎样让 run 不阻塞等待下个事件

Python sched.scheduler 的 run() 默认会等待下一个事件，所以直接调用它时，当前线程会被 delayfunc 占住。想让主循环自己决定何时回来处理调度器，应改用 run(blocking=False)：它只执行已经到期的事件，并返回距离下一个事件的时间差；队列为空时返回 None。

官方地址：https://docs.python.org/3/library/sched.html

这意味着非阻塞模式不是“完全不执行事件”，而是把“什么时候再次检查”交还给外层代码。文中配图均为静态结构说明图，用于解释接口关系，不是浏览器、终端或程序运行截图。

先看清 run 的阻塞边界

s.run() 等价于使用默认的 blocking=True。调度器会等待下一个事件的时间点，执行回调，再继续等待，直到队列没有事件。这个行为适合一个线程专门负责定时任务，却不适合还要处理输入、网络或其他循环的主线程。

非阻塞调用的返回值有两个用途：到期事件会在本次调用中执行；如果队列里仍有未来事件，返回值表示下一个事件距离当前时钟还有多少时间。这个数值不是新的事件对象，也不是布尔值，应该由宿主循环决定如何使用。

用 run(blocking=False) 接入外层轮询

外层循环可以把返回的延迟当作“建议的下一次检查时间”。如果宿主循环本身有固定节拍，可以只取它和固定节拍中的较小值；如果宿主循环支持按时唤醒，则可以直接使用这个延迟。关键是不要再调用一次默认阻塞的 run()。

import sched
import time


def refresh_cache(name):
    # 回调只负责业务动作；调度器负责决定它何时被调用。
    print(f"刷新缓存：{name}")


scheduler = sched.scheduler(time.monotonic, time.sleep)
scheduler.enter(2, 1, refresh_cache, argument=("商品列表",))
scheduler.enter(5, 1, refresh_cache, argument=("首页摘要",))

while not scheduler.empty():
    delay = scheduler.run(blocking=False)
    # 没有下个事件时不应把 None 传给 sleep；这里直接结束轮询。
    if delay is None:
        break
    # 外层循环可以在这里处理其他工作，再按建议时间回来检查。
    time.sleep(min(delay, 0.2))

示例中的 0.2 只是外层轮询的上限，不是 sched 的固定要求。若主循环还要处理输入或消息，可以把这段等待替换成宿主框架的超时等待；delay 仍然只表示调度队列的下一次时间边界。

空队列、取消和慢回调要分别处理

当队列为空时，非阻塞 run() 返回 None。不要把它当成零秒延迟，否则外层循环可能变成忙轮询。可以等待新的任务、执行其他工作，或在宿主事件循环下一次有任务时再调用。

enter() 和 enterabs() 都会返回事件对象，这个对象可以交给 cancel()。取消失败会抛出 ValueError，因此只有仍由当前调度器持有的事件才应取消。对于不再需要的超时任务，业务层应保留事件句柄，而不是扫描公开队列猜测目标。

如果某个回调执行时间超过了下一个事件的间隔，调度器会落后，但不会自动丢弃事件。此时需要由业务决定是否取消过期任务、合并任务，或者把耗时工作移出调度回调。非阻塞模式只能避免“等待下个事件”阻塞，不能把一个耗时回调变成异步任务。

按宿主环境选择接入方式

可以把判断压缩成一句话：需要调度器自己等，就使用默认的 run()；需要宿主循环保持控制，就使用 run(blocking=False)，把它返回的时间差当成调度建议，而不是强制睡眠命令。

相关问题

run(blocking=False) 会不会执行未来事件？

不会。它只执行时间已经到达的事件；如果队列中还有未来事件，会返回距离下一个事件的时间差。

队列为空时应该 sleep(0) 吗？

不应该直接把 None 当成零。空队列意味着当前没有下一次调度时间，应等待新的任务或交还宿主循环处理。

非阻塞模式能避免慢回调卡住主循环吗？

不能。它只避免等待未来事件；回调本身仍在调用 run() 的线程中执行。耗时任务需要拆分、转移到其他执行单元，或由业务主动取消和合并。