详解详解Python 多线程多线程 Timer定时器定时器/延迟执行、延迟执行、Event事件事件
主要介绍了Python 多线程 Timer定时器/延迟执行、Event事件的相关知识，本文给大家介绍的非常详细，具有
一定的参考借鉴价值,需要的朋友可以参考下
Timer继承子Thread类，是Thread的子类，也是线程类，具有线程的能力和特征。这个类用来定义多久执行一个函数。
它的实例是能够延迟执行目标函数的线程，在真正执行目标函数之前，都可以cancel它。
Timer源码：
class Timer(Thread):
def __init__(self, interval, function, args=None, kwargs=None):
Thread.__init__(self)
self.interval = interval
self.function = function
self.args = args if args is not None else []
self.kwargs = kwargs if kwargs is not None else {}
self.finished = Event()
def cancel(self):
"""Stop the timer if it hasn't finished yet."""
self.finished.set()
def run(self):
self.finished.wait(self.interval)
if not self.finished.is_set():
self.function(*self.args, **self.kwargs)
self.finished.set()
Timer类使用方法与Thread定义子线程一样，interval传入间隔时间，function传入线程执行的函数，args和kwargs传入函
数的参数。
提前cancel：
import threading
import time
def add(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计时器：
import threading
import logging
import time
logging.basicConfig(level=logging.INFO)
# class MyTimer(threading.Thread):
class MyTimer:
def __init__(self,interval,fn,args=None):
self.interval = interval
self.fn = fn
self.args = args
self.event = threading.Event()
def start(self):
threading.Thread(target=self.__do).start()
def cancel(self):
self.event.set()
def __do(self):
self.event.wait(self.interval)
if not self.event.is_set():
self.fn(*self.args)
def add(x,y):
logging.warning(x+y)
t = MyTimer(5,add,(4,5))
t.start()
# time.sleep(2)
# t.cancel()
评论0