我正在尝试将列表作为参数传递给pool.map(co_refresh, input_list)
。然而,pool.map
没有触发该功能co_refresh
。并且也没有返回错误。看起来这个过程挂在那里。
原始代码:
from multiprocessing import Pool
import pandas as pd
import os
account='xxx'
password='xxx'
threads=5
co_links='file.csv'
input_list=[]
pool = Pool(processes=threads)
def co_refresh(url, account, password, outputfile):
print(url + ' : ' + account + ' : ' + password + ' : ' + outputfile)
return;
link_pool = pd.read_csv(co_links, skipinitialspace = True)
for i, row in link_pool.iterrows():
ln = (row.URL, account, password, os.path.join('e:/', row.File_Name.split('.')[0] + '.csv'))
input_list.append(ln)
pool.map(co_refresh, input_list)
pool.close()
但是,它从未触发该功能co_refresh
。如何使用列表作为参数传递给我的函数?
老问题(简化):
我有下面的 input_list,这是一个list
of list
:
[a1, b1, c1, d1]
[a2, b2, c2, d2]
[a3, b3, c3, d3]
我有如下功能:
def func(a, b, c, d)
###
return;
我想使用多进程来实现此功能func
:
from multiprocessing import Pool
pool = Pool(processes=5)
pool.map(func, input_list)
pool.close()
但是,它从未触发该功能func
。如何使用列表作为参数传递给我的函数?