如何在Python 2.7中实现超时锁定

Question

有没有一种方法可以在Python中实现用于多线程目的的锁定，其acquire方法可以具有任意超时？到目前为止，我发现的唯一可行的解​​决方案是使用轮询，

• 我发现优雅和低效
• 不保留锁的有界等待/进度保证作为关键部分问题的解决方案

有没有更好的方法来实现这一目标？

Answer 1

详细阐述史蒂文的评论建议：

import threading
import time

lock = threading.Lock()
cond = threading.Condition(threading.Lock())

def waitLock(timeout):
    with cond:
        current_time = start_time = time.time()
        while current_time < start_time + timeout:
            if lock.acquire(False):
                return True
            else:
                cond.wait(timeout - current_time + start_time)
                current_time = time.time()
    return False

注意事项：

• 有两个threading.Lock()对象，一个在内部threading.Condition()。
• 操作时cond，获取了锁；wait()但是，该操作将其解锁，因此任何数量的线程都可以观看它。
• 等待被嵌入到for循环中，以跟踪时间。 threading.Condition可能会因为超时以外的其他原因而收到通知，因此，如果您确实希望时间到期，则仍然需要跟踪时间。
• 即使有条件，您仍然可以“轮询”真正的锁，因为它可能会唤醒多个线程并争夺该锁。如果lock.acquire失败，则循环返回等待状态。
• 此waitLock函数的调用者应lock.release()在acond.notify()后面加上a，以便通知正在等待该函数的其他线程重试获取该锁。该示例中未显示。