一、Queue的基本使用

1、导入模块

import multiprocessing

2、定义消息队列，并指定长度
如果不指定队列⻓度，则默认为最⼤
如果指定了消息队列的⼤⼩，则消息队列就有上限控制

queue = multiprocessing.Queue(3)

3、 向消息队列中放⼊内容,可以是任何类型的数据

queue.put(1) # 放⼊第⼀个值
queue.put("hello") # 放⼊第⼆个值
queue.put([1, 2, 3]) # 放⼊第三个值

4、 从消息队列中取出数据

print(queue)  # 打印队列对象

value1 = queue.get()  # 获取第⼀个值
print(value1)

value2 = queue.get()  # 获取第⼆个值
print(value2)

value3 = queue.get()  # 获取第三个值
print(value3)

二、Queue的常用方法

Queue.qsize()：返回当前队列包含的消息数量；
Queue.empty()：如果队列为空，返回True，反之False ；如果获取是否为空的进程和放置值的进程同时执⾏，值未放进去，empty() 已经开始取，使用该方法得到的结果可能是True。避免这种情况发生，可使用：：time.sleep(0.0001) 稍微休眠下。
Queue.full()：如果队列满了，返回True,反之False；
Queue.get([block[, timeout]])：获取队列中的⼀条消息，然后将其从列队中移除，block默认值为
True；
如果block使⽤默认值，且没有设置timeout（单位秒），消息列队如果为空，此时程序将被阻
塞（停在读取状态），直到从消息列队读到消息为⽌，如果设置了timeout，则会等待timeout
秒，若还没读取到任何消息，则抛出"Queue.Empty"异常；
如果block值为False，消息列队如果为空，则会⽴刻抛出"Queue.Empty"异常；
Queue.get_nowait()：相当Queue.get(False)；
Queue.put(item,[block[, timeout]])：将item消息写⼊队列，block默认值为True；
如果block使⽤默认值，且没有设置timeout（单位秒），消息列队如果已经没有空间可写⼊，
此时程序将被阻塞（停在写⼊状态），直到从消息列队腾出空间为⽌，如果设置了timeout，
则会等待timeout秒，若还没空间，则抛出"Queue.Full"异常；
如果block值为False，消息列队如果没有空间可写⼊，则会⽴刻抛出"Queue.Full"异常；
Queue.put_nowait(item)：相当Queue.put(item, False)；

三、Queue实现进程间通信

以Queue为例，在⽗进程中创建两个⼦进程，⼀个往Queue⾥写数据，⼀个从Queue⾥读数据。具体实现如下：

'''
1、创建队列，写入数据
2、从队列中读取数据
3、使用进程通信
'''

import  time
import multiprocessing

def queue_write(queue):
   for i in range(10):
       if queue.full():
           print("队列已满~~~")
           break
       queue.put(i)
       print(i)
       time.sleep(0.5)

def queue_read(queue):
   while True:
       if queue.empty():
           print("队列已空~~~")
           break
       result = queue.get()
       print(result)

if __name__ == '__main__':
   queue = multiprocessing.Queue(5)
   
   process_write = multiprocessing.Process(target=queue_write,args=(queue,))
   process_write.start()
   process_write.join()

   process_read = multiprocessing.Process(target=queue_read,args=(queue,))
   process_read.start()

输出结果：

0
1
2
3
4
队列已满~~~
0
1
2
3
4
队列已空~~~