我目前正在为Python中的压力测试编写一个连接管理器,看起来我的队列永远不会填满。这个pseudoesque-code将解释它比我更好:多进程的产生。进程没有在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
无论如何可以解释为什么我的队列大小为0?
此外,我没有意识到Queue.Queue和multiprocessing.Queue之间的区别! – afuzzyllama 2011-01-19 20:04:53