Python进程没有加入

Question

我无法粘贴我的代码片段,所以我将解释方案1.我有一个大约50000个股票的列表,需要一些估价2.这些股票在MultiProcess.Queue 3.我创建多个流程,每个流程将从队列中取出一批50个并做一​​些事情.4.在主线程中,我有一张看起来像这样的支票

 anymore_to_process = True

 while anymore_to_process:
     if (stock_queue.qsize() == 0):
         anymore_to_process = False

for jobs in stock_jobs:
    jobs.join()

5. 但是,当我处理50000条记录时,这似乎不起作用.如果我处理500股,这个工作正常.

我究竟做错了什么？当我处理大量股票时,为什么流程没有加入.

我知道如果不看我的代码就很难回答.....但如果你能给我一些指示,那将非常有帮助.

Answer 1

问题已解决 - 从@dano 的问题中得到了提示。我确实在写另一个队列，它阻塞了进程。我把它拿出来，问题解决了。