Как заблокировать метод в классе который работает в нескольких потоках?

Question

[Никита Рощенко]

Есть такой код в модуле Foo:

import time
count = 10

def updateCount():
    while 1:
        count += 1
        time.sleep(2)
        print count

И есть файл main.py в котором импортируется модуль Foo и в нескольких потоках запускается функция updateCount.

Как можно синхронизировать эту функцию, что бы пока идет sleep в другом потоке переменная не изменилась?

Answer 1

[Andrey K]

from threading import RLock
lock = RLock()

def updateCount():
    while 1:
        lock.acquire()
        count += 1
        time.sleep(2)
        print count
        lock.release()

Comments

[radioxoma]

def updateCount():
    while True:
        with lock:
            count += 1
            time.sleep(2)
            print(count)