custom_sharing.py 文件源码

def client_run(name, x, y, wait, external_lock=None):
    server_proc = Server(('localhost', 8080), authkey=b'none')
    server_proc.connect()
    S = server_proc.Struct()
    # Either use SyncManager.Lock(), or explicitly pass in a global mp.Lock()
    # object as args to client processes
    if not external_lock:
        print('No external_lock passed. Using server_proc.Lock() instead.')
    with external_lock or server_proc.my_lock():
        for i in range(5):
            S.update(x+i, y+i)
            if MEMORY_PROFILING:
                print(mp.current_process().pid, name, 'updated', i)
            else:
                print(name, *S.get())
            time.sleep(wait)