在 Python 3.4 中获取锁时如何正确尝试/捕获超时错误

Question

我将threading.RLock 用于多线程应用程序。我想让线程尝试获取锁，如果不成功，请重试几次，前提是重试所花费的时间低于某个超时阈值。

这就是我所拥有的

>>> import threading
>>> lock = threading.RLock()
>>> def worker():
        with lock.acquire(timeout=5):
            print('acquired')
>>> lock.acquire()
>>> t2 = threading.Thread(target=worker)
>>> t2.start()

这似乎有效，等待五秒钟后我得到一个异常：

>>> Exception in thread Thread-1:
Traceback (most recent call last):
  File "/Library/Frameworks/Python.framework/Versions/3.4/lib/python3.4/threading.py", line 920, in _bootstrap_inner
    self.run()
  File "/Library/Frameworks/Python.framework/Versions/3.4/lib/python3.4/threading.py", line 868, in run
    self._target(*self._args, **self._kwargs)
  File "<pyshell#7>", line 2, in test
AttributeError: __exit__

KeyboardInterrupt
>>> 
KeyboardInterrupt

AttributeError 看起来很奇怪 - 我们不应该看到某种超时错误吗？

我的问题是：

1. 我在 Python 3.4 中是否正确执行此操作？我一直在查看似乎针对 Python 2.7 的similar question asked on SO。此外，如果lock.acquire 接受超时参数，为什么我需要使用条件变量，我有些困惑。
2. 是否有更好的模式来重试 lock.acquire 并在重试之间设置超时/延迟？

Answer 1

锁是上下文管理器，但acquire 不返回上下文管理器。如果超时也不会抛出异常。

Lock.acquire 和 RLock.acquire 如果获得锁则返回 True，否则返回 False。要测试您是否获得了锁，只需检查返回值。不要使用with 或try-except。