7.2.6 - 并发多线程 队列

Posted 2020-10-26 如果迎着风就飞，俯瞰这世界有多美

 

队列介绍

进程彼此之间互相隔离，要实现进程间通信（IPC），multiprocessing模块支持两种形式：队列和管道，这两种方式都是使用消息传递的

创建队列的类（底层就是以管道和锁定的方式实现）：

Queue([maxsize]):创建共享的进程队列，Queue是多进程安全的队列，可以使用Queue实现多进程之间的数据传递。

参数介绍：

maxsize是队列中允许最大项数，省略则无大小限制。
但需要明确：
    1、队列内存放的是消息而非大数据
    2、队列占用的是内存空间，因而maxsize即便是无大小限制也受限于内存大小

主要方法介绍：

q.put方法用以插入数据到队列中。
q.get方法可以从队列读取并且删除一个元素。

from multiprocessing import Queue
q = Queue(3)      # 队列最大长度为3
q.put("hello")
q.put({‘a‘:1})
q.put([1,2,3])
# q.put(1)        #  在放就阻塞了，因为队列已经满了
print(q.full())   # 查看队列是否满了（满了就True）
for i in range(3):
    print(q.get())
print(q.empty())  # 查看队列是否空了（空了就True）
print(q.empty())  # 在取就阻塞了因为，队列没有数据，所以就阻塞