Python多重处理apply_async读/写变量在主进程启动子进程

Question

我使用的是Python 3.5多处理应用异步。我的代码类似于task=pool。应用异步（myFunc，args）。我在args中传递一个信息（来自信息的对象）。它有一个名为startTime的数据成员。我希望当myFunc开始运行时，info。开始时间将被写入时间。时间（）。问题是主流程中的信息和子流程中的信息不一样<代码>信息。开始时间=时间。myFunc中的time（）不会更改主进程中的信息。有没有一个好办法来挽救startTime？谢谢

Answer 1

池中的进程不能写入公共变量。把它们想象成存在于平行宇宙中。你需要一些机制来在他们之间共享信息。下面是一个使用Manager来保持所有进程的时间戳的简单示例：

from multiprocessing import Pool, Manager, current_process
import time

def do_work(x, ll):
    time.sleep(.2)
    ll.append(current_process().name + ' took task '+str(x)+' at '+str(time.time()))

if __name__ == '__main__':
    with Manager() as manager:
        timestamp = manager.list()
        p = Pool(processes=4)
        for x in range(10):
            p.apply_async(do_work, (x, timestamp))
        p.close()
        p.join()
        print(timestamp)

如果您更改timestamp=manager。list（）只需timestamp=list（），您将看到它不再工作。

另外，当您使用池时，队列似乎不容易处理。