失败到发电机的输出到功能图谱与Python-2.7

Question

这里多处理是我的代码：

from multiprocessing import Pool 

user_list = [1, 2, 3, 4, 5] 
def gen_pair(): 
    for u1 in reversed(user_list): 
     for u2 in reversed(list(range(1, u1))): 
      yield (u1, u2) 

def cal_sim(u_pair): 
    u1, u2 = u_pair 
    sim = sim_f(df[u1], df[u2]) 
    return sim 

pool = Pool(processes=6) 
vals = pool.map(cal_sim, gen_pair()) 
df2record = pd.DataFrame(columns=['u1', 'u2', 'js']) 
for v in vals: 
    print (v) 
pool.terminate() 

但是当我运行的代码，我得到了这样的错误：TypeError: unsupported operand type(s) for +: 'set' and 'set'。完整的TraceBack如下：

Traceback (most recent call last): 
    File "b.py", line 57, in <module> 
    main() 
    File "b.py", line 47, in main 
    vals = pool.map(cal_sim, gen_pair()) 
    File "yobichi/python/2.7.10_2/lib/python2.7/multiprocessing/pool.py", line 251, in map 
    return self.map_async(func, iterable, chunksize).get() 
    File "yobichi/python/2.7.10_2/lib/python2.7/multiprocessing/pool.py", line 567, in get 
    raise self._value 
TypeError: unsupported operand type(s) for +: 'set' and 'set' 

请问您能告诉我什么原因，我该如何处理它？

Answer 1

您这里有无限递归：

def cal_sim(u_pair): 
    u1, u2 = u_pair 
    sim = cal_sim(df[u1], df[u2]) 
    return sim 

因为cal_sim电话cal_sim没有任何结束条件。

参数也有问题，因为cal_sim有1个参数，您可以用2个参数调用它。