|
当队列大小是1409的时候,这个进程不会自动关闭,导致程序一直挂着,当大小是1408的时候,进程会退出,程序终止。为什么会这样?难道python的multiprocessing.Queue就是这么设计的吗? 代码如下:
- import multiprocessing
- def queueuein(queue):
- for x in range(1409):
- queue.put(x)
- print('queueuein 结束')
- if __name__ == '__main__':
- queue = multiprocessing.Queue()
- process = multiprocessing.Process(target=queueuein, args=(queue,))
- process.start()
- process.join()
- print('queue.qsinze() >>>', queue.qsize())
- print('close .....')
复制代码
|
|