доля dict между процессом

Question

У меня есть dict, который я хочу поделиться с 4 процессами, которые изменяют значения в этом dict в режиме реального времени. Файл dict создается с помощью Manager().dict() Вопрос в том, нужно ли блокировать ресурс каждый раз, когда процесс изменяет dict? Что делать, если 4 обрабатывает доступ к этому dict в режиме реального времени?

Answer 1

Тогда вы увидите неопределенное поведение. Вот простой тест программы:

def worker(t): 
    d, i = t 
    d[i % 10] += 1 

if __name__ == "__main__": 
    import multiprocessing as mp 
    pool = mp.Pool() 
    d = mp.Manager().dict() 
    for i in range(10): 
     d[i] = 0 
    pool.map(worker, ((d, i) for i in xrange(1000))) 
    pool.close() 
    pool.join() 
    print d, sum(d.values()) 

А вот пример вывода из 3-х серий:

{0: 97, 1: 96, 2: 98, 3: 96, 4: 96, 5: 99, 6: 97, 7: 96, 8: 96, 9: 94} 965 
{0: 97, 1: 97, 2: 96, 3: 97, 4: 97, 5: 97, 6: 95, 7: 95, 8: 93, 9: 96} 960 
{0: 98, 1: 97, 2: 98, 3: 96, 4: 97, 5: 95, 6: 97, 7: 97, 8: 97, 9: 98} 970 

Чтобы получить «ожидаемый» отсчет 100 в каждом ведре, вам нужно создать mp.Manager().Lock() объект слишком, передать его и использовать в worker() для защиты мутации dict.