欢迎访问 如意编程网!

如意编程网

当前位置: 首页 > 编程资源 > 编程问答 >内容正文

编程问答

队列模块(Queue)

发布时间:2024/7/5 编程问答 0 豆豆
如意编程网 收集整理的这篇文章主要介绍了 队列模块(Queue) 小编觉得挺不错的,现在分享给大家,帮大家做个参考.
#!/usr/bin/env python # coding=utf-8import Queue import time''' https://docs.python.org/2/library/queue.htmlQueue模块在Python 3中改名为queue了。 Queue模块实现了多个生产者消费者列队,可以在多线程中进行安全的信息交换。 Queue模块定义了三个类:Queue.Queue, Queue.LifoQueue, Queue.PriorityQueue,还包含两个异常:Queue.Empty, Queue.Full。 '''''' exception Queue.Empty: 如果队列为空,使用非阻塞的方法获取队列的值,如get()或get_nowait(),则抛出此异常。 '''''' exception Queue.Full: 如果队列已满,使用非阻塞的方法插入值,如put()或put_nowait(),则抛出此异常。 '''''' Queue的方法: qsize():获取队列的大概容量,是大概容量!!! empty():是否空。 full():是否满。 put(item[, block[, timeout]]):数据入队,默认block是True,timeout为None,队列满则阻塞;如果block为True,timeout > 0,则等待timeout秒,队列仍为满则抛Full异常;如果block为False,则队列满立刻抛Full异常。 put_nowait(item):等同于put(item, block=False)。 get([block[, timeout]]):数据移出队列,默认block是True,timeout为None,队列空则阻塞;如果block为True,timeout > 0,则等待timeout秒,队列仍为空则抛Empty异常;如果block为False,则队列空立刻抛Empty异常。 get_nowait():等同于get(block=False)。 task_done():指示正常入队的数据任务已完成。在get()后再调用task_done()则告诉队列此项数据任务已完成。如果调用的次数比数据项的数目多,则抛出ValueError异常。 join():队列一直阻塞,直到所有数据出列并处理。新入列数据项,总数据项增加1。当数据出列,处理完后调用task_done()则表示处理完毕,总数据项减1。 '''''' class Queue.Queue(maxsize=0): 先入先出队列,maxsize是指定最大容量,如果为0或负值,则队列容量可以无穷大。队列满还插入则会阻塞。 ''' def operate_queue():q = Queue.Queue()print u'队列空吗?{0}'.format(q.empty())q.put('data1')q.put('data2')q.put('data3')print u'队列满吗?{0}'.format(q.full())print q.get()print q.get()print q.get()try:print u'时间点:{0}'.format(time.ctime())q.get(timeout=3) # 阻塞3秒,然后抛Empty异常except Queue.Empty:print u'时间点:{0}'.format(time.ctime())print u'队列已经空了'try:print u'时间点:{0}'.format(time.ctime())q.get_nowait() # 即刻抛Empty异常except Queue.Empty:print u'时间点:{0}'.format(time.ctime())print u'队列已经空了'try:print u'时间点:{0}'.format(time.ctime())q.get(block=False) # 即刻抛Empty异常except Queue.Empty:print u'时间点:{0}'.format(time.ctime())print u'队列已经空了'print u'队列大概容量为:{0}'.format(q.qsize())q = Queue.Queue(maxsize=3)q.put('d1')q.put('d2')q.put('d3')try:print u'时间点:{0}'.format(time.ctime())q.put('d4', block=False) # 即刻抛Full异常except Queue.Full:print u'时间点:{0}'.format(time.ctime())print u'队列已经满了'''' class Queue.LifoQueue(maxsize=0): 后入先出队列,maxsize是指定最大容量,如果为0或负值,则队列容量可以无穷大。队列满还插入则会阻塞。 ''' def operate_lifoqueue():q = Queue.LifoQueue()q.put(1)q.put(2)q.put(3)print q.get()print q.get()print q.get()''' class Queue.PriorityQueue(maxsize=0): 优先队列,maxsize是指定最大容量,如果为0或负值,则队列容量可以无穷大。队列满还插入则会阻塞。 典型的队列数据为元组(priority_num, data),优先值越小,优先级越高。 ''' def operate_priorityqueue():q = Queue.PriorityQueue() # 数字小优先级高q.put((1, 'YaoMing'))q.put((-1, 'MaLong'))q.put((10, 'ZhengZhi'))q.put((5, 'ZhuTing'))print q.get()print q.get()print q.get()print q.get()if __name__ == '__main__':print u'先进先出队列:'operate_queue()print '*' * 50print u'后进先出队列:'operate_lifoqueue()print '*' * 50print u'优先队列:'operate_priorityqueue()''' 输出为:先进先出队列: 队列空吗?True 队列满吗?False data1 data2 data3 时间点:Thu Jun 27 16:33:27 2019 时间点:Thu Jun 27 16:33:30 2019 队列已经空了 时间点:Thu Jun 27 16:33:30 2019 时间点:Thu Jun 27 16:33:30 2019 队列已经空了 时间点:Thu Jun 27 16:33:30 2019 时间点:Thu Jun 27 16:33:30 2019 队列已经空了 队列大概容量为:0 时间点:Thu Jun 27 16:33:30 2019 时间点:Thu Jun 27 16:33:30 2019 队列已经满了 ************************************************** 后进先出队列: 3 2 1 ************************************************** 优先队列: (-1, 'MaLong') (1, 'YaoMing') (5, 'ZhuTing') (10, 'ZhengZhi') '''

源码可于github下载:https://github.com/gkimeeq/PythonLearning。

转载于:https://www.cnblogs.com/Ooman/p/11096656.html

创作挑战赛新人创作奖励来咯,坚持创作打卡瓜分现金大奖

总结

以上是如意编程网为你收集整理的队列模块(Queue)的全部内容,希望文章能够帮你解决所遇到的问题。

如果觉得如意编程网网站内容还不错,欢迎将如意编程网推荐给好友。