我想知道 multiprocessing 模块中是否有一个本机实现,它允许我将正在运行的进程存储在基于列表的结构中,并且每当进程完成执行时,它会自动从列表中删除。
在代码中它看起来像这样:
from multiprocessing import process
pool = [] # This data structure needs to prune non-running processes
class A(Process):
def run():
pass
for i in range(0, 10):
worker = A().start()
pool.append(worker)
# So if I want to iterate the pool now, It should only contain the alive processes
另一种管理方法是保留字典:
pool = {
processId: processObject
}
然后使用 psutil 获取活动进程 ID:
current_process = psutil.Process()
children = current_process.children(recursive=False)
但是,一旦进程终止,字典中对象的大小是多少?
相关分类