python模块学习（queue模块的Q

学习版本3.5.2

PriorityQueue类和LifoQueue类继承Queue类然后重写了_init、_qsize、_put、_get这四个类的私有方法

Queue：先进先出队列的同步实现，通过双向列表实现的

代码语言：javascript复制

    # Initialize the queue representation
    def _init(self, maxsize):
        self.queue = deque()

    def _qsize(self):
        return len(self.queue)

    # Put a new item in the queue
    def _put(self, item):
        self.queue.append(item)

    # Get an item from the queue
    def _get(self):
        return self.queue.popleft()

PriorityQueue：优先队列的同步实现，通过堆实现

代码语言：javascript复制

    def _init(self, maxsize):
        self.queue = []

    def _qsize(self):
        return len(self.queue)

    def _put(self, item):
        heappush(self.queue, item)

    def _get(self):
        return heappop(self.queue)

LifoQueue：后进先出队列的同步实现，通过list来实现的

代码语言：javascript复制

    def _init(self, maxsize):
        self.queue = []

    def _qsize(self):
        return len(self.queue)

    def _put(self, item):
        self.queue.append(item)

    def _get(self):
        return self.queue.pop()

__init__(self, maxsize=0) 初始化队列长度，maxsize为0的时候长度为无限

empty(self) 返回队列是否为空

full(self) 返回队列是否为满

qsize(self) 返回队列的大小（并不可靠）

get(self, block=True, timeout=None) 从队头获取并删除元素，block为true：timeout为None时候，阻塞当前线程直到队列中有可用元素；timeout为非负时候，等了timeout的时间还没有可用元素时候抛出一个Empty异常；block为false：timeout为None时候，队列为空则抛出Empty异常；timeout为非负时候，等待timeout时候后没有可用元素则抛出Empty异常。

get_nowait(self) #return self.get(block=False)

put(self, item, block=True, timeout=None) 在队尾插入一个元素，block为true：timeout为None时候，阻塞当前线程直到队列中有可用位置；timeout为非负时候，等了timeout时间还没有可用位置时候抛出一个Full异常；block为false：timeout为None时候，队列没有位置则抛出Full异常；timeout为非负时候，等待timeout时候后还是没有可用位置则抛出Full异常。

put_nowait(self, item) ＃return self.put(item, block=False)

join(self) 阻塞当前线程直到队列的任务全部完成了

task_done(self) 通知队列任务的完成情况，当完成时候唤醒被join阻塞的线程

实验代码

代码语言：javascript复制

#/usr/bin/python3
# -*- utf-8 -*-
#学习版本3.5.2

import threading
import time
import queue

que = queue.Queue(5)
#que = queue.PriorityQueue(5)
#que = queue.LifoQueue(5)

def que_put(item):
    que.put(item)
    print("put", item)
    time.sleep(1)

def que_get():
    item = que.get()
    print("get", item)
    que.task_done()

def que_join():
    que.join()
    print("task was done")

if __name__ == "__main__":
    putthreadlist = []
    getthreadlist = []
    tlist = [4,5,6,1,2,3]
    for i in tlist:
        putthreadlist.append(threading.Thread(target=que_put,args=(i,)))
    for i in range(6):
        getthreadlist.append(threading.Thread(target=que_get))


    for tl in putthreadlist:
        tl.start()

    threading.Thread(target=que_join).start()

    for tl in getthreadlist:
        tl.start()

    print("main")

运行结果

代码语言：javascript复制

put 4
put 5
put 6
put 1
put 2
get 4
put 3
get 5
get 6
get 1
get 2
get 3
main
task was done

que = queue.PriorityQueue(5)时候的运行结果

代码语言：javascript复制

put 4
put 5
put 6
put 1
put 2
get 1
put 3
get 2
get 3
get 4
get 5
get 6
main
task was done

que = queue.LifoQueue(5)时候的运行结果

代码语言：javascript复制

put 4
put 5
put 6
put 1
put 2
get 2
put 3
get 3
get 1
get 6
get 5
get 4
main
task was done

block join queue self timeout

0 人点赞