問題描述

代碼比較簡單

import multiprocessingimport timelist1 = [1,2,3]def func(msg): list1[0] = 99 return 'done ' + msgif __name__ == '__main__': pool = multiprocessing.Pool(processes=4) for i in range(10):msg = 'hello %d' % (i)pool.apply_async(func, (msg,)) pool.close() pool.join() print (list1)

因為真實的環境比較多,所以簡化了代碼,我大概的需求就是list1是一個比較多的數據列表,然后在多線程處理的時候,每次更新其中一項數據...

但是我運行以后,發現list1還是[1,2,3] , 我理想應該是[99,2,3]

有高手指點一下要如何實現嗎?

問題解答

不好意思，你用的multiprocessing是多進程而不是多線程，每個進程中的變量都是獨立的，

你應該使用threading，這個才是多線程

如果你堅持用multiprocessing，就必須用共享變量，你可以將list里的數據存入Queue中，Queue是python中的共享隊列，用于多進程通信的