Threading Python. Làm thế nào để khóa một sợi?

Question

Tôi đang cố gắng hiểu các khái niệm cơ bản về luồng và đồng thời. Tôi muốn một trường hợp đơn giản, nơi hai chủ đề liên tục cố gắng truy cập vào một tài nguyên được chia sẻ.

Mã:

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() 

Vì vậy, tôi có hai đề, cả hai cố gắng để tăng bộ đếm. Tôi nghĩ rằng nếu chuỗi 'A' được gọi là incre(), thì lock sẽ được thiết lập, ngăn không cho 'B' truy cập cho đến khi 'A' được phát hành.

Chạy để làm rõ rằng đây không phải là trường hợp. Bạn nhận được tất cả các số liệu ngẫu nhiên của cuộc đua.

Đối tượng khóa được sử dụng chính xác như thế nào?

Chỉnh sửa, Ngoài ra, tôi đã thử đặt các khóa bên trong các chức năng của chuỗi, nhưng vẫn không có may mắn.

Answer 1

Bạn có thể thấy rằng các khóa của mình hoạt động khá nhiều khi bạn đang sử dụng chúng, nếu bạn làm chậm quá trình và làm cho chúng bị chặn nhiều hơn một chút. Bạn đã có ý tưởng đúng, nơi bạn bao quanh các đoạn mã quan trọng bằng khóa. Dưới đây là một điều chỉnh nhỏ cho ví dụ của bạn để cho bạn thấy cách mỗi người chờ đợi nhau để giải phóng khóa.

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() 

Mẫu đầu ra:

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