Есть небольшой код, в котором в разных процессах увеличивается на единицу переменная из порождающего процесса:
from multiprocessing import Process, Pipe, Lock
counter = 0
def foo(pipe, c):
c += 1
pipe.send(c)
if __name__ == '__main__':
childEnd, parentEnd = Pipe()
for n in range(3):
Process(target=foo, args=(childEnd, counter)).start()
with Lock():
counter = parentEnd.recv()
print('counter = %s' % counter)
Вопрос: нужен ли Lock перед изменением переменной? Так как инкрементирование происходит с помощью канала Pipe, не пойму нужно ли предохраняться перед изменением общей переменной?