定时器

在实际应用中，我们经常需要使用定时器去触发一些事件。Python中通过线程实现定时器timer,其使用非常简单 示例：使用定时器实现当前时间每秒循环输出一次 代码：

import threading#导入线程类 import time#导入python中的time类 def run():#定义run方法，执行实际逻辑结构 print(time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())) # 以%Y-%m-%d %H:%M:%S的格式输出显示当前的时间 t = threading.Timer(1, function=run)#重新初始化一个定时器的线程时间设为1秒 t.start()#执行线程 if __name__ == '__main__':#创建主线程 t = threading.Timer(1,function=run)#重新初始化一个定时器的线程时间设为1秒 t.start()#执行线程

注意：也可以使用t = threading.Timer(1, function=run,args=x)来初始化一个带有参数方法的定时器

队列

Python的Queue模块中提供了同步的、线程安全的队列类，包括FIFO（先入先出)队列Queue，LIFO（后入先出）队列LifoQueue，和优先级队列PriorityQueue。这些队列都实现了锁原语，能够在多线程中直接使用。可以使用队列来实现线程间的同步。

from Queue import Queue,LifoQueue,PriorityQueue #先进先出队列 q=Queue(maxsize=5) #后进先出队列 lq=LifoQueue(maxsize=6) #优先级队列 pq=PriorityQueue(maxsize=5) for i in range(5): q.put(i) lq.put(i) pq.put(i) print "先进先出队列：%s;是否为空：%s；多大,%s;是否满,%s" %(q.queue,q.empty(),q.qsize(),q.full()) print "后进先出队列：%s;是否为空：%s;多大,%s;是否满,%s" %(lq.queue,lq.empty(),lq.qsize(),lq.full()) print "优先级队列：%s;是否为空：%s,多大,%s;是否满,%s" %(pq.queue,pq.empty(),pq.qsize(),pq.full()) print q.get(),lq.get(),pq.get() print "先进先出队列：%s;是否为空：%s；多大,%s;是否满,%s" %(q.queue,q.empty(),q.qsize(),q.full()) print "后进先出队列：%s;是否为空：%s;多大,%s;是否满,%s" %(lq.queue,lq.empty(),lq.qsize(),lq.full()) print "优先级队列：%s;是否为空：%s,多大,%s;是否满,%s" %(pq.queue,pq.empty(),pq.qsize(),pq.full())

常用方法： Queue.qsize() 返回队列的大小 Queue.empty() 如果队列为空，返回True,反之False Queue.full() 如果队列满了，返回True,反之False，Queue.full 与 maxsize 大小对应 Queue.get([block[, timeout]])获取队列，timeout等待时间 Queue.get_nowait() 相当于Queue.get(False)，非阻塞方法 Queue.put(item) 写入队列，timeout等待时间 Queue.task_done() 在完成一项工作之后，Queue.task_done()函数向任务已经完成的队列发送一个信号。每个get()调用得到一个任务，接下来task_done()调用告诉队列该任务已经处理完毕。 Queue.join() 实际上意味着等到队列为空，再执行别的操作

线程池

由于线程预先被创建并放入线程池中，同时处理完当前任务之后并不销毁而是被安排处理下一个任务，因此能够避免多次创建线程，从而节省线程创建和销毁的开销，能带来更好的性能和系统稳定性。

步骤：

调用 ThreadPoolExecutor 类的构造器创建一个线程池。 定义一个普通函数作为线程任务。 调用 ThreadPoolExecutor 对象的 submit() 方法来提交线程任务。 当不想提交任何任务时，调用 ThreadPoolExecutor 对象的 shutdown() 方法来关闭线程池。 ThreadPoolExecutor(线程池)

from concurrent.futures import ThreadPoolExecutor import requests pool = ThreadPoolExecutor(10) def task(url): response = requests.get(url) print(url,response) url_list = ( "https://www.baidu.com", "https://www.bilibili.com", ) for url in url_list: pool.submit(task,url) pool.shutdown(wait=True)