使用Multiprocessing starmap_async时如何获取Pool ID以终止指定进程池？

核心问题是你现在用单个self.pool变量保存进程池，新活动启动时会覆盖旧的，导致无法追踪每个活动对应的池。直接用字典映射活动名称和进程池就能解决，具体步骤如下：

1. 用字典存储每个活动的进程池 #

初始化一个字典来保存不同活动对应的Pool对象，键用活动名称（比如"Camp1"），值可以同时存进程池实例和异步任务结果，方便后续追踪状态：

# 在类初始化时创建字典
def __init__(self):
    self.camp_pools = {}  # 键：活动名称，值：(进程池实例, 异步任务结果)

# 启动活动的代码修改为：
camp_name = "Camp1"  # 替换为UI选中的活动名称
pool = Pool(processes=10)
p = list(itertools.product(searchengines, selecteddomains, searchterms))
params = [(a, api, camp_name, da, pidfileloc, proxies,
                       logfileloc, hours, domainfileloc,
                       siteregistration, mozapi, mozsecret) for a in p]
async_result = pool.starmap_async(Expired_Search, params)
# 把进程池和任务结果存入字典
self.camp_pools[camp_name] = (pool, async_result)

2. 按活动名称终止指定进程池 #

当需要终止某个活动的进程池时，直接从字典中取出对应的Pool实例，调用terminate()强制终止（如果要等待现有任务完成再关闭，用close()加join()组合）：

def stop_selected_camp(self, camp_name):
    if camp_name in self.camp_pools:
        pool, _ = self.camp_pools.pop(camp_name)  # 取出后从字典移除，避免重复操作
        pool.terminate()  # 强制终止该池的所有子进程
        pool.join()  # 等待子进程资源清理完成

额外提示 #

• 如果需要检查活动任务的状态（比如是否完成），可以通过保存的async_result对象调用ready()、successful()等方法。
• 启动新活动前，可以先检查字典中是否已有该活动的条目，避免重复创建进程池造成资源浪费。

内容的提问来源于stack exchange，提问作者Naveen