python中队列基本操作和多线程队列的示例分析

这篇文章给大家分享的是有关python中队列基本操作和多线程队列的示例分析的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

一、队列基本操作

from queue import Queue

q = Queue(5)  # 创建一个容量为5的队列。如果给一个小于0的数，则队列为无限大小。（这是官方的解释，实际不是无限大小，而是跟内存有关）

# 存储数据
q.put(123)  # 数值 
q.put('hello world!')  # 字符串
q.put(['hello', 'world'])  # 列表
q.put(('hello', 'world'))  # 元组
q.put({'hello': 'world'})  # 字典

# 如果再试图存储第六个，则会发生阻塞，因为容量已设定为5
# q.put({'hello': 'python'})

取出队列中的值：

print(q.get())
print(q.get())
print(q.get())
print(q.get())
print(q.get())

如图五个值被依次取出。Queue队列遵循的是先进先出。

q.put_nowait()

q.put_nowait()方法可以无阻碍地向队列中添加内容，如果队列已满则会立即报错，不会等待（即不会发生阻塞）。

q.get_nowait()

q.get_nowait()方法可以无阻碍地从队列中取出内容，如果队列是空的则也会直接报错，不会等待。
具体使用不再示例。

查看队列当前大小

q.qsize()

print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())
print(q.get())
print(q.qsize())

如图，每取出一个值，队列大小就减一。同样每存入一个值队列大小就会加一。

q.full()

判断队列是否是满的。

q.empty()

判断队列是否是空的。

print(q.full())
print(q.get())
print(q.get())
print(q.full())
print(q.empty())
print(q.get())
print(q.get())
print(q.get())
print(q.empty())

二、多线程队列

from queue import Queue
import threading
import time


# 存储值，每隔一秒存储一个
def set_value(q):
    num = 0
    while True:
        q.put(num)
        num += 1
        time.sleep(1)

# 取值，不间断地取
def get_value(q):
    while True:
        print(q.get())


if __name__ == '__main__':
    q = Queue(4)
    t1 = threading.Thread(target=set_value, args=(q, ))
    t2 = threading.Thread(target=get_value, args=(q, ))

    t1.start()
    t2.start()

程序开始运行，一边存储，一边取值：

此思想应用在爬虫上，即一边访问并获取数据，一边下载数据。

感谢各位的阅读！关于“python中队列基本操作和多线程队列的示例分析”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！