python|python 包中的sched 事件调度器的操作方法 python包中的sched事件调度器的操

一、延迟运行事件

在一个延迟或规定时间之后执行事件，需要采用enter()方法，参数如下：
间隔时间 ( 具体值决定与delayfunc，这里为秒 )
优先级 ( 两个事件在同一时间到达时，先执行哪一个 )
调用的函数
函数参数

import schedimport time# 生成调度器scheduler = sched.scheduler(time.time, time.sleep)def print_event(name):print ('EVENT:', time.time(), name)print ('START:', time.time())# 分别设置在执行后2秒、3秒之后执行调用函数scheduler.enter(2, 1, print_event, ('first',))scheduler.enter(3, 1, print_event, ('second',))# 运行调度器scheduler.run()# 输出结果# START: 1532050215.3737717# EVENT: 1532050217.3747234 first# EVENT: 1532050218.375626 second

二、重叠事件

调用 run() 块执行所有的事件
每个事件都在同一线程中运行，所以如果一个事件需要更长的时间，延迟事件将会有重叠。
为了不丢失事件，延迟事件将会在之前事件运行完再被执行
但一些延迟事件可能会晚于原本计划的事件

import schedimport timescheduler = sched.scheduler(time.time, time.sleep)def long_event(name):print('BEGIN EVENT :', time.time(), name)time.sleep(2)print('FINISH EVENT:', time.time(), name)print('START:', time.time())scheduler.enter(2, 1, long_event, ('first',))# 事件无法在设想的3秒后执行，将会顺延执行scheduler.enter(3, 1, long_event, ('second',))scheduler.run()# 输出结果# START: 1532051082.8237524# BEGIN EVENT : 1532051084.8392828 first# FINISH EVENT: 1532051086.8475456 first# BEGIN EVENT : 1532051086.8475456 second# FINISH EVENT: 1532051088.8557353 second

三、事件优先级如果多个事件是同一时间执行，通过设置他们的优先级值，用于确定顺序运行

import schedimport timescheduler = sched.scheduler(time.time, time.sleep)def print_event(name):print('EVENT:', time.time(), name)now = time.time()print('START:', now)scheduler.enterabs(now+2, 2, print_event, ('first',))scheduler.enterabs(now+2, 1, print_event, ('second',))scheduler.run()# 输出结果# START: 1532052567.6057265# EVENT: 1532052569.621258 second# EVENT: 1532052569.621258 first

四、取消事件利用enter()和enterabs()返回一个引用事件用来取消它

import schedimport threadingimport timescheduler = sched.scheduler(time.time, time.sleep)# 建立一个全局线程计数器counter = 0def increment_counter(name):global counterprint('EVENT:', time.time(), name)counter += 1print('NOW:', counter)print('START:', time.time())e1 = scheduler.enter(2, 1, increment_counter, ('E1',))e2 = scheduler.enter(3, 1, increment_counter, ('E2',))# 开始一个线程执行事件t = threading.Thread(target=scheduler.run)t.start()# 在主线程,取消第一个预定事件scheduler.cancel(e1)# 等待线程调度程序完成运行t.join()# 输出结果# START: 1532053265.5280123# EVENT: 1532053268.528813 E2# NOW: 1

五、其他方法