1. from multiprocessing import Queue
    2. # 初始化一个队列, 可以设置大小, 如果队列已满超过的会等待队列有空位置
    3. q = Queue(3)
    4. q.put('消息 1')
    5. q.put('消息 2')
    6. q.put('消息 3')
    7. # 返回队列是否已满
    8. if not q.full():
    9. q.put('消息 4')
    10. else:
    11. print('队列已满')
    12. # 队列当前大小
    13. print(q.qsize())
    14. # 读取队列中的值并删除
    15. print(q.get())
    16. print(q.full())
    17. print(q.get())
    18. print(q.full())