星风雪宇 2020-04-25 19:46 采纳率: 100%
浏览 964
已采纳

Python多进程修改共享变量的问题

from multiprocessing import Pool,freeze_support,Lock
import time
cnt=0
lock=Lock()
def test(item):
    with lock:
        global cnt
        time.sleep(1)
        cnt=cnt+1
if __name__=='__main__':
    freeze_support()
    start=time.time()
    pool=Pool()
    pool.map(test,range(0,10))
    pool.close()
    pool.join()
    print(cnt)
    print(time.time()-start)

用python开多进程执行某个test任务,test任务简化为一个延时操作,每进行一次test就让共享变量加1,使用了multiprocessing中的锁Lock()来解决数据竞争的问题,发现无法解决,每次print的cnt值还是0(如果成功解决数据竞争问题的话cnt最后应该是10),请问应该怎么改?

  • 写回答

4条回答 默认 最新

  • 吃鸡王者 2020-04-26 14:37
    关注

    多线程共享变量一般这么写:

    from multiprocessing import freeze_support,Lock,Process,Value
    import time
    
    cnt=Value('i',0)
    lock=Lock()
    
    def my_test(cnt,lock):
        with lock:
            time.sleep(1)
            cnt.value+=1
            print(cnt.value)
    if __name__=='__main__':
        freeze_support()
        ps=[Process(target=my_test,args=(cnt,lock)) for i in range(10)]
        start=time.time()
        for p in ps:
            p.start()
        for p in ps:
            p.join()
        print(cnt.value)
        print(time.time()-start)
    
    

    建议:pool个人认为一般用相对独立的并行处理,个进程之间几乎没有交集,所以对于共享变量建议还是不要用pool,
    还有就是,在windos系统下,pool对自定义的方法,一般会报错(需要将自定义的函数在另一个文件中定义,用import导入后使用),所以你的代码里其实各个子进程都没有执行,详情你可以在一个shell里边逐行
    运行检查一下。

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(3条)

报告相同问题?

悬赏问题

  • ¥50 python课程管理系统
  • ¥15 python+selenium,在新增时弹出了一个输入框
  • ¥15 苹果验机结果的api接口哪里有??单次调用1毛钱及以下。
  • ¥20 学生成绩管理系统设计
  • ¥15 来一个cc穿盾脚本开发者
  • ¥15 CST2023安装报错
  • ¥15 使用diffusionbert生成文字 结果是PAD和UNK怎么办
  • ¥15 有人懂怎么做大模型的客服系统吗?卡住了卡住了
  • ¥20 firefly-rk3399上启动卡住了
  • ¥15 如何删除这个虚拟音频