重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
本文实例讲述了Python queue队列原理与应用。分享给大家供大家参考,具体如下:
创新互联公司,是成都地区的互联网解决方案提供商,用心服务为企业提供网站建设、重庆APP开发公司、成都微信小程序、系统按需网站设计和微信代运营服务。经过数十多年的沉淀与积累,沉淀的是技术和服务,让客户少走弯路,踏实做事,诚实做人,用情服务,致力做一个负责任、受尊敬的企业。对客户负责,就是对自己负责,对企业负责。作用:
解耦:使程序直接实现松耦合,修改一个函数,不会有串联关系。
提高处理效率:FIFO = 现进先出,LIFO = 后入先出。
队列:
队列可以并发的派多个线程,对排列的线程处理,并切每个需要处理线程只需要将请求的数据放入队列容器的内存中,线程不需要等待,当排列完毕处理完数据后,线程在准时来取数据即可。请求数据的线程只与这个队列容器存在关系,处理数据的线程down掉不会影响到请求数据的线程,队列会派给其他线程处理这分数据,它实现了解耦,提高效率。队列内会有一个有顺序的容器,列表与这个容器是有区别的,列表中数据虽然是排列的,但数据被取走后还会保留,而队列中这个容器的数据被取后将不会保留。当必须在多个线程之间安全地交换信息时,队列在线程编程中特别有用。
参数介绍:
# 先入先出 maxsize 可设置大小,设置block=False抛异常 class queue.Queue(maxsize=0) # 后进先出 class queue.LifoQueue(maxsize=0) # 存储数据时可设置优先级的队列 # 优先级设置数越小等级越高 class queue.PriorityQueue(maxsize=0) # 放入数据 Queue.put(item, block=True, timeout=None) # 取出数据 #没有数据将会等待 Queue.get(block=True, timeout=None) # 如果1秒后没取到数据就退出 Queue.get(timeout = 1) # 取数据,如果没数据抛queue.Empty异常 Queue.get_nowait() # 查看队列大小 Queue.qsize() # 返回True,如果空 Queue.empty() #return True if empty # 设置队列大小 Queue.full() # 后续调用告诉队列,任务的处理是完整的。 Queue.task_done()