第四节 多进程中的队列

import multiprocessing

'''
q = multiprocessing.Queue(3)
q.put(1)
q.put_nowait(0)
q.get()
q.get_nowait()
q.full()
q.empty()
# 放入的元素超过定义的个数，程序会处于阻塞状态，get方法一样。两者都可以通过调用q.get_nowait()让其报错强制退出程序
'''

def put_data(q):
    """写入数据"""
    data = [11, 22, 33, 44, 55, 66]
    for x in data:
        q.put(x)
    print('.............数据写入完成............')

def download_data(q):
    """处理数据"""
    data = list()
    while True:
        data.append(q.get())
        if q.empty():  # 当数据没取完会处于阻塞状态
            break
    print(data)
    print('数据处理完了')

def main():
    q = multiprocessing.Queue(10)
    p2 = multiprocessing.Process(target=download_data, args=(q,))
    p1 = multiprocessing.Process(target=put_data, args=(q,))
    p1.start()
    p2.start()


if __name__ == '__main__':
    main()