0

如果答案很明显,对不起这个幼稚的问题。我觉得我在 python 中的多处理模块上苦苦挣扎,因为我真的不知道发生了什么。代码如下:

pool=Pool()
for i in xrange(1000000):
    for j in xrange(i+1,1000000):
        pool.apply_async(myfun,((i,j),),callback=mycallback)

我的想法是通过将每个 apply_async 分配给一个核心(我有 16 个核心)来并行化这个大 for 循环。然而,16 名工人中只有 4 或 5 人在工作,而其他人则处于闲置状态。有任何想法吗?先感谢您。

ps 回调函数很简单。它有点像制作 myfun 返回的值的直方图。

4

0 回答 0