如何知道是否发布了Python multiprocessing.Lock?

Jua*_*nti 4 python multithreading multiprocessing

>>> l = Lock()
>>> l.acquire()
True
>>> l.release()
>>> l.release()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
ValueError: semaphore or lock released too many times
Run Code Online (Sandbox Code Playgroud)

抛出ValueError异常.如何防止多次释放锁定?像l.is_released()这样的东西?

ddo*_*nko 8

问题有点不清楚.您需要使用信号量而不是锁或检查锁是否被锁定.

例如,Python的锁与.Net上的锁不同.Python的Lock一旦解锁就会释放在同一个锁上获取()并暂时被阻止的所有其他线程.任何线程都可以释放,所有线程都可以同时运行.所以,不要做第二次重复,而是做

if l.locked():
    l.release()
Run Code Online (Sandbox Code Playgroud)

如果你想要"队列"行为,只有一个脚本会在其他版本发布后获得锁的所有权,使用Semaphore,Event或其他允许嵌套锁定和排队行为的类似类.

有趣的是,其他语言/ loolkits,如.Net,本身会锁定队列,线程可以按顺序堆积lock.acquire,按获取队列的顺序阻止并获取锁定对象的所有权,而不是一次性释放所有.

(编辑:忘了把父母放在"if l.locked:l.realse()"中.更正了代码.确认Lock.locked是cPython 2.6.x,3.x,IronPython 2.6.1中的当前方法)

  • >>> from multiprocessing import Lock >>> Lock().locked traceback(最近一次调用last):文件"<stdin>",第1行,在<module>中AttributeError:'Lock'对象没有属性'locked' (7认同)
  • “multiprocessing”模块中的锁没有“locked”方法,但“threading”模块有“locked”方法 (2认同)

Jer*_*own 7

期望是获取锁的上下文应该知道何时应该释放它.在什么情况下你会尝试多次释放它?

  • 要么让您的尝试更精细,要么利用上下文管理器(使用my_lock :)来保证释放锁定. (2认同)