开发笔记:python_并发编程——数据共享

from multiprocessing import Manager,Process
class MyPro(Process):
def __init__(self,dic):
super().__init__()
self.dic = dic
def run(self):
self.dic[\'count\'] -= 1
print(self.dic)
if __name__ == \'__main__\':
m = Manager()
dic = m.dict({\'count\':100})
p = MyPro(dic)
p.start()
p.join()
print(\'主进程：\',dic)

from multiprocessing import Manager,Process,Lock
class MyPro(Process):
def __init__(self,dic,lock):
super().__init__()
self.dic = dic
self.lock = lock
def run(self):
self.lock.acquire()
self.dic[\'count\'] -= 1
self.lock.release()
# print(self.dic)
if __name__ == \'__main__\':
lock = Lock()
m = Manager()
dic = m.dict({\'count\':100})
p_list = []
for i in range(50):
p = MyPro(dic,lock)
p.start()
p_list.append(p)
for i in p_list:
p.join()
print(\'主进程:\',dic)