История изменений

Исправление rtxtxtrx, 11.05.24 12:50 (текущая версия) :

import multiprocessing as mp

_lock = mp.RLock()

def worker(...):
  ...
  with _lock:
    mp_dict['shit'] = ... 

mp_dict = mp.Manager().dict()

p1 = mp.Process(target=worker, args=(...))
p1.start()

p2 = mp.Process(target=worker, args=(...))
p2.start()

p1.join()
p2.join()

Исправление rtxtxtrx, 11.05.24 12:50:

import multiprocessing as mp

_lock = mp.RLock()

def worker(...):
  with _lock:
    mp_dict['shit'] = ... 

mp_dict = mp.Manager().dict()

p1 = mp.Process(target=worker, args=(...))
p1.start()

p2 = mp.Process(target=worker, args=(...))
p2.start()

p1.join()
p2.join()

Исходная версия rtxtxtrx, 11.05.24 12:49:

import multiprocessing as mp

_lock = mp.RLock()

def worker(...):
  with _lock:
    mp_dict['shit'] = ... 

mp_dict = mp.Manager().dict()

p1 = mp.Process(target=worker, args=(...))
p1.start()

p2 = mp.Process(target=worker, args=(...))
p2.start()