Python 队列在当前完成之前跳转到下一项

Question

我使用一个队列从另一个线程接收任务，然后一个接一个地完成它。线程模块根据磁盘上的文件创建事件将项目放入队列，主线程应该按照先进先出的原则逐个处理添加到队列中的文件。处理一个任务/文件可能需要几秒到一分钟。

我面临的问题是，与使用queue.get（）以同步方式逐个处理队列项相反，有时会有多个并发进程以异步方式启动。代码如下所示：

#code in main thread
q = Queue.Queue(0)
while True:
    qItem = q.get()
    do_something_with(qItem)  # this may take few seconds to minutes

#code in other thread
items = ['one', 'two', 'three']
for item in items:
    q.put(item)

上面的代码应该处理项目“一”然后是“二”，然后是“三”。在我的实际程序中会发生什么，do_something_with 方法在处理项目“一”完成之前开始处理项目“二”。

Answer 1

您正在将列表附加到l。这就是导致错误的原因。

l.append（outl[a：b]） 创建列表的一部分 outl 并将该列表添加到 l

使用< code>l.extend(outl[a:b])

Answer 2

如果我没记错的话，您创建的线程比您想象的要多！

你是用< code > if _ _ name _ _ = ' _ _ main _ _ ':守护主块吗？

否则，您可能只是创建了比您意识到的更多的线程，并且它们可能正在消耗队列中的项目。