python - 并行处理中的迭代

Question

我认为我已经很接近了，但我无法找出迭代输入的正确方法。这是我的代码示例:

from multiprocessing import Pool
from functools import partial
from itertools import product

def f(n, x, y):
    return print("{} {} {}".format(n, x, y))

n = 3

c = [[1,2,3],[4,5,6]]
d = [[7,8,9],[10,11,12]]


if __name__ == '__main__':
    p = Pool(3)
    func = partial(f, n)
    p.starmap(func, product(zip(c,d), repeat=2))

这是结果:

3 ([1, 2, 3], [7, 8, 9]) ([1, 2, 3], [7, 8, 9])
3 ([1, 2, 3], [7, 8, 9]) ([4, 5, 6], [10, 11, 12])
3 ([4, 5, 6], [10, 11, 12]) ([1, 2, 3], [7, 8, 9])
3 ([4, 5, 6], [10, 11, 12]) ([4, 5, 6], [10, 11, 12])

但我想要的是

3 ([1, 2, 3], [7, 8, 9]) 
3 ([1, 2, 3], [10, 11, 12])
3 ([4, 5, 6], [7, 8, 9])
3 ([4, 5, 6], [10, 11, 12])

Answer 1

您的预期输出只是 c 和 d 的乘积，因此没有理由zip 或重复。

更改:

p.starmap(func, product(zip(c,d), repeat=2))

至:

p.starmap(func, product(c, d))

演示:https://repl.it/repls/GoodWorthwhileLeadership