問題描述

代碼比較簡單

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)

因?yàn)檎鎸?shí)的環(huán)境比較多,所以簡化了代碼,我大概的需求就是list1是一個(gè)比較多的數(shù)據(jù)列表,然后在多線程處理的時(shí)候,每次更新其中一項(xiàng)數(shù)據(jù)...

但是我運(yùn)行以后,發(fā)現(xiàn)list1還是[1,2,3] , 我理想應(yīng)該是[99,2,3]

有高手指點(diǎn)一下要如何實(shí)現(xiàn)嗎?

問題解答

不好意思，你用的multiprocessing是多進(jìn)程而不是多線程，每個(gè)進(jìn)程中的變量都是獨(dú)立的，

你應(yīng)該使用threading，這個(gè)才是多線程

如果你堅(jiān)持用multiprocessing，就必須用共享變量，你可以將list里的數(shù)據(jù)存入Queue中，Queue是python中的共享隊(duì)列，用于多進(jìn)程通信的