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

Recommended Posts

lock et Rlock
[linux] Swap CapsLock et Ctrl
À propos de _ et __