4

当使用从 pprocess 调用的函数时，我似乎无法在 Python 中修改全局变量。这是我的例子：

import pprocess
import time

numbers=[0,0,0,0,0,0,0,0,0,0]

# find system time and store in global variable
def find_time(index):
    global numbers
    x=time.time()
    print "Setting element %s of numbers to %f" % (index, x)
    numbers[index]=x
    return x

# parallel execution of the function
results=pprocess.pmap(find_time, [0,1,2,3,4,5,6,7,8,9], limit=6)

for y in results:
    print '%f' % y

# this list is unchanged
print numbers

# serial execution of the function
for x in [0,1,2,3,4,5,6,7,8,9]:
    find_time(x)

# now it seems to work
print numbers

“数字”只是一个零列表，为了演示，我试图将每个列表元素设置为当前系统时间。当使用 pprocess 调用时，这不起作用，但是当我使用简单的 for 循环调用函数时，全局变量会被更改。

我花了一些时间阅读有关全局变量的信息，并真诚地希望这不是一个微不足道的问题。有人可以向我解释发生了什么吗？

非常感谢，

远野

4

2 回答 2

1

我的理解是在引擎盖下pprocess使用。subprocessing如果是这种情况，那么每次运行该函数时，它实际上都是一个单独的进程。因此，当您的函数返回时，这些更改不会出现。

您可能需要将列表设为multiprocessing.Manager.

例如

numbers = multiprocessing.Manager().list([0]*10)
于 2012-09-27T13:18:51.883 回答
0

pprocess创建另一个进程。这意味着它不与调用代码共享内存。并行进程修改的任何内容都将在其自己的内存空间中进行修改，因此调用代码的内存空间将保持不变。也就是说 - 它们不共享全局变量。

您必须通过管道或任何pprocess提供或套接字等显式地在两者之间进行所有通信。

于 2012-09-27T13:18:00.653 回答