事件调度
sched
模块内容很简单,只定义了一个类。它用来最为一个通用的事件调度模块。
class sched.scheduler(timefunc, delayfunc)
这个类定义了调度事件的通本文来源gaodai$ma#com搞$$代**码网用接口,它需要外部传入两个参数,timefunc
是一个没有参数的返回时间类型数字的函数(常用使用的如time模块里面的time),delayfunc
应该是一个需要一个参数来调用、与timefunc的输出兼容、并且作用为延迟多个时间单位的函数(常用的如time模块的sleep)。
下面是一个列子:
import sched, times = sched.scheduler(time.time, time.sleep) # 生成调度器def print_time():print "From print_time", time.time()def print_some_times():print time.time()s.enter(5, 1, print_time, ()) # 加入调度事件# 四个参数分别是:# 间隔事件(具体值决定与delayfunc, 这里为秒);# 优先级(两个事件在同一时间到达的情况);# 触发的函数;# 函数参数;s.enter(10, 1, print_time, ())# 运行s.run()print time.time()if __name__ == '__main__':print_some_times()
看到的输出结果,隔5秒中执行第一个事件,隔10秒后执行第二个事件:
1499259731.99From print_time 1499259736.99From print_time 1499259741.991499259741.99
在多线程场景中,会有线程安全问题,run()函数会阻塞主线程。官方建议使用threading.Timer
类代替:
import timefrom threading import Timerdef print_time():print "From print_time", time.time()def print_some_times():print time.time()Timer(5, print_time, ()).start()Timer(10, print_time, ()).start()time.sleep(11) # 阻塞主线程,等待调度程序执行完毕,再执行后面内容print time.time()if __name__ == '__main__':print_some_times()
Scheduler对象方法
scheduler对象拥有下面这些方法或属性:
-
scheduler.enterabs(time, priority, action, argument)
加入一个事件,time
参数应该是一个与传递给构造函数的timefunc
函数的返回值相兼容的数值类型。在同一时间到达的事件将按照priority
顺序执行。
执行事件其实就是执行action(argument)
。argument必须是一个包含action
参数的序列。
返回值是一个事件,它可以用于稍后取消事件(请参见cancel()
)。