Python进程、线程、协程详解(4)

当前位置:

首页 > Python基础教程 >

Python进程、线程、协程详解(4)

6、queue模块

Queue 就是对队列，它是线程安全的

举例来说，我们去麦当劳吃饭。饭店里面有厨师职位，前台负责把厨房做好的饭卖给顾客，顾客则去前台领取做好的饭。这里的前台就相当于我们的队列。形成管道样，厨师做好饭通过前台传送给顾客，所谓单向队列

这个模型也叫生产者-消费者模型。

						import queue

						q = queue.Queue(maxsize=0)  # 构造一个先进显出队列，maxsize指定队列长度，为0 时，表示队列长度无限制。

						q.join()    # 等到队列为kong的时候，在执行别的操作

						q.qsize()   # 返回队列的大小 （不可靠）

						q.empty()   # 当队列为空的时候，返回True 否则返回False （不可靠）

						q.full()    # 当队列满的时候，返回True，否则返回False （不可靠）

						q.put(item, block=True, timeout=None) #  将item放入Queue尾部，item必须存在，可以参数block默认为True,表示当队列满时，会等待队列给出可用位置，

						　　　　　　　　　　　　　　　　　　　　　　　　 为False时为非阻塞，此时如果队列已满，会引发queue.Full 异常。 可选参数timeout，表示 会阻塞设置的时间，过后，

						　　　　　　　　　　　　　　　　　　　　　　　　  如果队列无法给出放入item的位置，则引发 queue.Full 异常

						q.get(block=True, timeout=None) #   移除并返回队列头部的一个值，可选参数block默认为True，表示获取值的时候，如果队列为空，则阻塞，为False时，不阻塞，

						　　　　　　　　　　　　　　　　　　　　　　若此时队列为空，则引发 queue.Empty异常。 可选参数timeout，表示会阻塞设置的时候，过后，如果队列为空，则引发Empty异常。

						q.put_nowait(item) #   等效于 put(item,block=False)

						q.get_nowait() #    等效于 get(item,block=False)

代码如下：

						#!/usr/bin/env python

						import Queue

						import threading

						message = Queue.Queue(10)

						def producer(i):

						    while True:

						        message.put(i)

						def consumer(i):

						    while True:

						        msg = message.get()

						for i in range(12):

						    t = threading.Thread(target=producer, args=(i,))

						    t.start()

						for i in range(10):

						    t = threading.Thread(target=consumer, args=(i,))

						    t.start()

栏目列表