Enhebrado de Python. ¿Cómo bloqueo un hilo?

Question

Estoy tratando de entender los conceptos básicos de subprocesamiento y concurrencia. Quiero un caso simple en el que dos hilos intenten acceder repetidamente a un recurso compartido.

El código:

import threading 

class Thread(threading.Thread): 
    def __init__(self, t, *args): 
     threading.Thread.__init__(self, target=t, args=args) 
     self.start() 
count = 0 
lock = threading.Lock() 

def incre(): 
    global count 
    lock.acquire() 
    try: 
     count += 1  
    finally: 
     lock.release() 

def bye(): 
    while True: 
     incre() 

def hello_there(): 
    while True: 
     incre() 

def main():  
    hello = Thread(hello_there) 
    goodbye = Thread(bye) 

    while True: 
     print count 

if __name__ == '__main__': 
    main() 

lo tanto, tengo dos hilos, ambos tratando de incrementar el contador. Pensé que si el hilo 'A' se llamaba incre(), se establecería el lock, impidiendo que 'B' accediera hasta que se haya liberado 'A'.

Al ejecutar, deja en claro que este no es el caso. Obtienes todos los incrementos aleatorios de datos aleatorios.

¿Cómo se usa exactamente el objeto de bloqueo?

Editar, Además, he intentado poner los bloqueos dentro de las funciones de subprocesos, pero todavía no tuve suerte.

Answer 1

Puede ver que sus bloqueos funcionan bastante mientras los está utilizando, si reduce la velocidad del proceso y los bloquea un poco más. Tuviste la idea correcta, donde rodeas pedazos críticos de código con la cerradura. Aquí hay un pequeño ajuste a su ejemplo para mostrarle cómo cada uno espera al otro para liberar el bloqueo.

import threading 
import time 
import inspect 

class Thread(threading.Thread): 
    def __init__(self, t, *args): 
     threading.Thread.__init__(self, target=t, args=args) 
     self.start() 

count = 0 
lock = threading.Lock() 

def incre(): 
    global count 
    caller = inspect.getouterframes(inspect.currentframe())[1][3] 
    print "Inside %s()" % caller 
    print "Acquiring lock" 
    with lock: 
     print "Lock Acquired" 
     count += 1 
     time.sleep(2) 

def bye(): 
    while count < 5: 
     incre() 

def hello_there(): 
    while count < 5: 
     incre() 

def main():  
    hello = Thread(hello_there) 
    goodbye = Thread(bye) 


if __name__ == '__main__': 
    main() 

Salida de ejemplo:

... 
Inside hello_there() 
Acquiring lock 
Lock Acquired 
Inside bye() 
Acquiring lock 
Lock Acquired 
...