python – 内置sched模块的非阻塞scheduler.run()方法的用法？

2019年7月28日 244次阅读

我想了解如何在方法
scheduler.run(blocking=True)中使用可选参数阻塞.任何实际/现实世界的例子都会非常有用.

根据我迄今为止所做的研究,阻塞可选参数的意图是非阻塞或异步应用程序[1] [2].下面是schduler的主要运行循环(来自python 3.6库sched.py).通过代码,我注意到每当阻塞设置为False时,立即返回目标时间和当前时间之间的时间差,除非目标时间已经过去,在这种情况下将执行操作.

while True:
    with lock:
        if not q:
            break
        time, priority, action, argument, kwargs = q[0]
        now = timefunc()
        if time > now:
            delay = True
        else:
            delay = False
            pop(q)
    if delay:
        if not blocking:
            return time - now
        delayfunc(time - now)
    else:
        action(*argument, **kwargs)
        delayfunc(0)   # Let other threads run

在我看来,非阻塞设计要求我继续运行调度程序,直到队列清理为止.因此,我正在考虑自己维护一个任务队列,并继续将scheduler.run任务推入队列(如下面的代码.)这是一个理想的设计吗？使用非阻塞调度程序的正确方法是什么？

def action():
    print('action at: ', datetime.now())

if __name__ == '__main__':
    s = sched.scheduler(time.time)
    target_time = datetime.now() + timedelta(seconds=5)
    s.enterabs(target_time.timestamp(), 1, action)
    run = functools.partial(s.run, blocking=False)
    taskq = deque()
    taskq.append(run)
    while taskq:
        task = taskq.popleft()
        result = task()
        print(result)
        if result:
            taskq.append(run)
            time.sleep(1)

    print('end tasks')

[1] What’s New In Python 3.3

[2] Issue13449: sched – provide an “async” argument for run() method

最佳答案 老问题,但我刚刚实现了非常有效地使用非阻塞版本的东西.

当sched.scheduler.run中的blocking = True时,它将调用delayfunc作为时间差,直到下一个事件.

如果您的应用程序在t = 0时为t = 10调度事件A,则这可能是不合需要的,但是另一个线程在t = 1时为t = 5调度事件B.在这种情况下,

s = sched.scheduler(time.time)
# Spawn threads which enter A and B into s
while True:
    s.run(True)

如果你的主线程只是在一个循环中调用sched.scheduler.run(blocking = True),那么在t = 0时它将调用delayfunc(10),因为它只看到它有10个时间单位,直到A.主线程赢了直到t = 10才醒来,此时它会看到它错过了B,迟到了B 5时间单位,然后在B之后运行A.

要解决此问题,您可以将主线程更改为如下所示：

s = sched.scheduler(time.time)
# Spawn threads which enter A and B into s
while True:
    next_ev = s.run(False)
    if next_ev is not None:
        time.sleep(min(1, next_ev))
    else:
        time.sleep(1)

此代码将捕获所有当前事件,然后睡眠直到下一个事件,或者如果没有下一个事件或者如果下一个事件太远,则将睡眠1秒.

理想情况下,调度程序将使用条件变量实现,以便新事件到达优先级队列的前端,并且它可以等待该变量,而不是直到下一个事件才睡觉.这将是最有效和最准确的时间.

点赞