多进程-多参数
多进程-多参数

多进程-多参数

import multiprocessing.dummy

def update(self, item, table_name):
    conn, cursor = self.connectPostgreSQL()
    company_name = item.get('project_company_name')
    id = item.get('id')
    ...

with multiprocessing.dummy.Pool(processes=20) as pool:
    table_name = "table"
    pool.starmap(self.update, zip(items, repeat(table_name)))

发表回复

您的电子邮箱地址不会被公开。