lock et Rlock
import logging
import threading
import time
logging.basicConfig(level=logging.DEBUG, format='%(threadName)s: %(message)s')
def worker1(d, lock):
logging.debug('start')
#Aucun autre thread ne sera traité tant que le traitement à l'intérieur du bloc with lock n'est pas terminé.
with lock:
i = d['x']
time.sleep(5)
d['x'] = i + 1
logging.debug(d)
#serrure avec fonction principale= threading.Lock()Si vous le faites, le processus ne se poursuivra pas
with lock:
d['x'] = i + 1
logging.debug('end')
def worker2(d, lock):
logging.debug('start')
#lock.acuire()Et verrouiller.Les autres threads ne seront pas traités tant que la pièce entourée par la libération ne sera pas traitée
lock.acquire()
i = d['x']
d['x'] = i + 1
logging.debug(d)
lock.release()
logging.debug('end')
if __name__ == '__main__':
d = {'x': 0}
lock = threading.RLock()
t1 = threading.Thread(target=worker1, args=(d, lock))
t2 = threading.Thread(target=worker2, args=(d, lock))
t1.start()
t2.start()
production
Thread-1: start
Thread-2: start
Thread-1: {'x': 1}
Thread-1: end
Thread-2: {'x': 2}
Thread-2: end