python - python Rlock 如何工作以及 Rlock 的所有者是什么？

Question

我目前正在练习python多线程模块，我写了一些代码如下，但它并没有像我预期的那样工作。

import threading
import thread
import random
import time
lock = threading.RLock()
def func(lock):
    print("In Thread " + threading.currentThread().getName())
    lock.acquire()
    time.sleep(random.random()*10)
    lock.release()
    print("Out Thread " + threading.currentThread().getName())

def start():
    lock.acquire()
    for i in range(5):
        thread.start_new(func, (lock,))
    lock.release()

# for i in range(5):
#     thread.start_new(func, (lock,))
start()

print("test")
time.sleep(1)
lock.acquire()
print("main ends")
lock.release()

在我看来，主线程是否有time.sleep(1)对新线程的运行影响不大，因为锁是全局的，属于主线程，lock.acquire()操作会总是工作正常，所以主线程不应该等待那些新线程继续进行。根据 thread.start_new() 的特性，当主线程结束时，所有新线程也会停止。然而，当我注释掉 time.sleep() 行时，程序按照我的预期进行，但是当我添加这一行时，主线程总是等待新线程完成。

这让我很困惑，希望有人能向我解释 Rlock() 的功能以及当我在主线程中创建它时它属于哪个线程，同时将它传递给子新线程并调用 lock .acquire()?

Answer 1

锁属于上次成功执行 .acquire() 的线程，直到 .release()d。

A RLock , re-entrant lock 的缩写是一种锁，它可以被最初获取它的同一个线程多次获取；锁保持锁定并由线程持有，直到每个获取被释放。

这里的重入意味着执行进入了一段由锁保护的代码，而锁已经被持有。您的代码没有演示需要重入锁的情况，但假设您有函数:

def guarded_op():
    with lock:
        print("Now doing 1 op")
        another_op()

def another_op():
    with lock:
        print("Now did the another op")

不可重入锁在那里不起作用，因为在 protected 操作中“锁已经被锁定”；锁定将在 another_op 中失败；但是 RLock 工作得很好。

顺便说一下，你应该尽可能使用带有锁的with语句来确保它们的有序释放。