进程共享变量

def (arg1,arg2,flag):
    while 1:
        if flag.value>0:
            return
        try:
            if(arg1<3):
                raise Exception("xxx")
        except Exception as a:
            print(f"{os.getpid()}errod:{a}")
            sleep(1)
        else:
            flag.value=arg1+arg2
            print(f"{os.getpid()}else,",flag.value)
if __name__ == '__main__':
    pool=multiprocessing.Pool()
    manager=multiprocessing.Manager()
    flag=manager.Value("i",0)
    for i in range(1,4):
        pool.apply_async(test,(i,i+1,flag))
    pool.close()
    pool.join()
    print(f"flag:{flag.value}")

def (arg1,arg2,flag):
    while 1:
        if flag.value>0:
            return
        try:
            if(arg1<3):
                raise Exception("xxx")
        except Exception as a:
            print(f"{os.getpid()}errod:{a}")
            sleep(1)
        else:
            flag.value=arg1+arg2
            print(f"{os.getpid()}else,",flag.value)
if __name__ == '__main__':
    flag=multiprocessing.Value("i",0)
    ps = [multiprocessing.Process(target=test, args=(x, x+1, flag)) for x in range(4)]
    for p in ps:
        p.start()
    for p in ps:
        p.join()
    print(f"flag:{flag.value}")