多进程的 Spawn.Process 在 Python 中未正确填充队列

Question

我目前正在用 Python 编写一个用于压力测试的连接管理器，看起来我的队列永远不会填满。这个伪代码会比我更好地解释它：

def wget(processQueue)
    currProcess = subprocess.Popen(./wget)
    processQueue.put(currProcess)

def connection(processQueue)
    process = multiprocessing.Process(target=wget, args=(processQueue,))
    process.start()

processQueue = Queue.Queue()
newConnection = multiprocessing.Process(target=connection, args=(processQueue,))
newConnection.start()
processQueue.qsize() # This is 0

Can无论如何解释为什么我的队列大小为0？

Answer 1

关于processQueue.qsize，请注意文档说：

Definition: processQueue.qsize(self)
Docstring:
    Return the approximate size of the queue (not reliable!).

所以您不应该依赖qsize来告诉您队列是否为空。

另外，由于您可能在调用 processQueue.put 之前到达 processQueue.qsize 行，因此队列此时可能确实是空的但不会永远空虚。