[問題] 新手請教multiprocessing

看板Python作者Casval (卡斯巴爾)時間12年前 (2013/05/25 13:15)推噓0(0推 0噓 20→)

留言20則, 2人參與討論串1/1

不好意思直接貼程式碼..我想包一個父類別可以自動切割資料讓子類別平行運算，算完後再把結果加總。但單程跟多程跑出來的結果不同，可能資料在多程中被亂寫了.. 請問怎麼設計才是正確的？ import multiprocessing class Super: def main(self): pass def result(self): return [] def join(self, result=[]): pass def Run(self, param): for i in range(param): self.main() return self.result() def SingleRun(self): result = [] for i in range(10): result.append(self.Run(i)) self.join(result) def MultiRun(self): pool = multiprocessing.Pool(processes=4) result = [] for i in range(10): result.append(pool.apply_async(self.Run, (i,))) pool.close() pool.join() result = [r.get() for r in result] self.join(result) class Child(Super): def __init__(self): self.total = 0 def main(self): self.total += 1 def result(self): return self.total def join(self, result=[]): total = 0 for r in result: total += r print('the result is', total) c = Child() if __name__ == '__main__': c.SingleRun() c.__init__() c.MultiRun() -- ※ 發信站: 批踢踢實業坊(ptt.cc) ◆ From: 210.209.142.12 ※ 編輯: Casval 來自: 210.209.142.12 (05/25 16:26)

→

Casval

05/25 17:08, , 1^F

05/25 17:08, 1^F

→

Casval

05/25 17:16, , 2^F

05/25 17:16, 2^F

→

swpoker

05/26 02:12, , 3^F

05/26 02:12, 3^F

→

Casval

05/26 08:05, , 4^F

05/26 08:05, 4^F

補上後來改的版本，運算結果為55 import multiprocessing class Super: def init(self): pass def main(self): pass def result(self): return [] def join(self, result=[]): pass def Run(self, param): for i in range(param): self.main() return self.result() def SingleRun(self): result = [] for i in range(1,11): self.init() result.append(self.Run(i)) self.join(result) def MultiRun(self): pool = multiprocessing.Pool(processes=4) result = [] for i in range(1,11): result.append(pool.apply_async(func=self.Run, args=(i,))) pool.close() pool.join() result = [r.get() for r in result] self.join(result) class Child(Super): def init(self): self.total = 0 def main(self): self.total += 1 def result(self): return self.total def join(self, result=[]): total = 0 for r in result: total += r print('the result is', total) c = Child() if __name__ == '__main__': c.init() c.SingleRun() c.init() c.MultiRun() ※ 編輯: Casval 來自: 210.209.142.12 (05/26 08:07)