【Python】定时器、队列、线程池

时间：2022-10-19 13:54:27

定时器

在实际应用中，我们经常需要使用定时器去触发一些事件。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)
标签：

相关文章