代码如下,当队列大小是1409的时候,这个进程不会自动关闭,导致程序一直挂着,当大小是1408的时候,进程会退出,程序终止。为什么会这样?当另一个线程或者进程消费到1407的时候又会退出。头大
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() print('queue.qsinze() >>>', queue.qsize()) print('close .....')
Sign in to make a reply
_swayer
代码如下,当队列大小是1409的时候,这个进程不会自动关闭,导致程序一直挂着,当大小是1408的时候,进程会退出,程序终止。为什么会这样?当另一个线程或者进程消费到1407的时候又会退出。头大