我正在创建一个小型应用程序,它将执行 4 个不同的、耗时的任务,以便第一个的输出是第二个的输入,依此类推。 在每个任务级别,输出都附加到列表,下一个任务弹出、操作并将其输出附加到其输出列表,依此类推…… 我认为完成任务的方法是在这 4 个任务中的每一个上都有多个线程。
问题来了,有没有什么方法可以让我的应用程序根据其输入队列中的任务数量在每个任务级别生成线程?
说第二个任务的输入列表一开始是空的,所以线程数是零,但是如果有一个任务,就会产生单个线程,两个线程等……当然还有一个上限线程数为 10,因此如果输入列表的长度高达 100,则运行的线程数仍保持在 10。
请建议实现此目标的 pythonic 方法。
请您参考如下方法:
您已经成功发明了Thread Pool .有内置支持,有很多 libraries和 examples将为您提供此功能,因此请使用一个或从他们的代码中学习。
from multiprocessing.pool import ThreadPool
