详解Python 多线程 Timer定时器/延迟执行、Event事件
Timer继承子Thread类,是Thread的子类,也是线程类,具有线程的能力和特征。这个类用来定义多久执行一个函数。
它的实例是能够延迟执行目标函数的线程,在真正执行目标函数之前,都可以cancel它。
Timer源码:
classTimer(Thread): def__init__(self,interval,function,args=None,kwargs=None): Thread.__init__(self) self.interval=interval self.function=function self.args=argsifargsisnotNoneelse[] self.kwargs=kwargsifkwargsisnotNoneelse{} self.finished=Event() defcancel(self): """Stopthetimerifithasn'tfinishedyet.""" self.finished.set() defrun(self): self.finished.wait(self.interval) ifnotself.finished.is_set(): self.function(*self.args,**self.kwargs) self.finished.set()
Timer类使用方法与Thread定义子线程一样,interval传入间隔时间,function传入线程执行的函数,args和kwargs传入函数的参数。
提前cancel:
importthreading importtime defadd(x,y): print(x+y) t=threading.Timer(10,add,args=(4,5)) t.start() time.sleep(2) t.cancel() print("===end===")
运行结果:
===end===
start方法执行之后,Timer对象会处于等待状态,等待10秒之后会执行add函数。同时,在执行add函数之前的等待阶段,主线程使用了子线程的cancel方法,就会跳过执行函数结束。
使用event事件实现Timer计时器:
importthreading importlogging importtime logging.basicConfig(level=logging.INFO) #classMyTimer(threading.Thread): classMyTimer: def__init__(self,interval,fn,args=None): self.interval=interval self.fn=fn self.args=args self.event=threading.Event() defstart(self): threading.Thread(target=self.__do).start() defcancel(self): self.event.set() def__do(self): self.event.wait(self.interval) ifnotself.event.is_set(): self.fn(*self.args) defadd(x,y): logging.warning(x+y) t=MyTimer(5,add,(4,5)) t.start() #time.sleep(2) #t.cancel()
运行结果:
WARNING:root:9
Event事件,是线程间通信机制中最简单的实现,使用一个内部的标记flag,通过flag的True或False的变化来进行操作。
Event源码:
classEvent:
def__init__(self): self._cond=Condition(Lock()) self._flag=False def_reset_internal_locks(self): self._cond.__init__(Lock()) defis_set(self): returnself._flag isSet=is_set defset(self): withself._cond: self._flag=True self._cond.notify_all() defclear(self): withself._cond: self._flag=False defwait(self,timeout=None): withself._cond: signaled=self._flag ifnotsignaled: signaled=self._cond.wait(timeout) returnsignaled
Event方法:
•set() flag设置为True
•clear() flag设置为False
•is_set() flag是否为True,返回布尔值
•wait(timeout=None) 设置等待flag变为True的时长,None为无限等待。等到了返回True,未等到超时了就返回False。
举例:
老板雇佣了一个工人,让他生产杯子,老板一直等着工人,直到生产了10个杯子。
importthreading importlogging importtime logging.basicConfig(level=logging.INFO) cups=[] event=threading.Event()#event对象 defboss(e:threading.Event): ife.wait(30):#最多等待30秒 logging.info('Goodjob.') defworker(n,e:threading.Event): whileTrue: time.sleep(0.5) cups.append(1) logging.info('make1') iflen(cups)>=n: logging.info('Ifinishedmyjob.{}'.format(len(cups))) e.set()#flag设置为True break b=threading.Thread(target=boss,name='boos',args=(event,)) w=threading.Thread(target=worker,args=(10,event)) w.start() b.start()
运行结果:
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:make1
INFO:root:Ifinishedmyjob.10
INFO:root:Goodjob.
老板和工人使用同一个Event对象的标记flag。
老板wait()设置为最多等待30秒,等待flag变为True,工人在做够10杯子时,将flag设置为True,工人必须在30秒之内没有做好杯子。
wait的使用:
importthreading importlogging logging.basicConfig(level=logging.INFO) defdo(event:threading.Event,interval:int): whilenotevent.wait(interval):#notevent.wait(1)=True logging.info('Todosth.') e=threading.Event() t=threading.Thread(target=do,args=(e,1)) t.start() e.wait(10)#也可以使用time.sleep(10) e.set() print('ManExit.')
运行结果:
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
INFO:root:Todosth.
ManExit.
wait与sleep的区别是:wait会主动让出时间片,其它线程可以被调度,而sleep会占用时间片不让出。
小结:
Timer定时器继承自Thread类,也是线程类。它的作用是等待n秒钟之后执行某个目标函数,可以使用cancel提前取消。
Event事件是通过True和False维护一个flag标记值,通过这个标记的值来决定做某事,wait()方法可以设置最长等待flag设置为Ture的时长,超时还未设置为True就返回False。
PS:下面看下python之定时器Timer
timer类
Timer(定时器)是Thread的派生类,用于在指定时间后调用一个方法。
构造方法:
Timer(interval,function,args=[],kwargs={}) interval:指定的时间 function:要执行的方法 args/kwargs:方法的参数
实例方法:
Timer从Thread派生,没有增加实例方法。
例子一:
#encoding:UTF-8 importthreading deffunc(): print'hellotimer!' timer=threading.Timer(5,func) timer.start()
线程延迟5秒后执行。
总结
以上所述是小编给大家介绍的详解Python多线程Timer定时器/延迟执行、Event事件,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!