Python 进程线程之间通信方式(2.1,共享数据实现进程之间通信)

复习补充内容

#!/usr/bin/env python
# -*- coding:utf-8 -*-

# Author:xp
# blog_url: http://blog.csdn.net/wuxingpu5/article/details/71209731

from multiprocessing import Manager, Process, Lock


def work(d, mutex):
    with mutex:
        d['count'] -= 1
    # mutex.release()


if __name__ == '__main__':
    mutex = Lock()
    m = Manager()
    d = m.dict({'count': 100})
    p_l = []
    for i in range(100):
        p = Process(target=work, args=(d,mutex))
        p_l.append(p)
        p.start()

    for p in p_l:
        p.join()
    print('主线程:', d)


Logo

CSDN联合极客时间,共同打造面向开发者的精品内容学习社区,助力成长!

更多推荐