标签:重入 == 结果 read self 请求 run UI 可重入锁
死锁现象与递归锁所谓死锁:是指两个或两个以上的进程或线程在执行过程中,因争夺资源而造成的一种互相等待的现象
如下就是死锁:
from threading import Thread,Lock
import time
mutexA=Lock()
mutexB=Lock()
class MyThread(Thread):
def run(self):
self.f1()
self.f2()
def f1(self):
mutexA.acquire()
print(‘%s 拿到了A锁‘ %self.name)
mutexB.acquire()
print(‘%s 拿到了B锁‘ % self.name)
mutexB.release() #1
mutexA.release() #0
def f2(self):
mutexB.acquire()
print(‘%s 拿到了B锁‘ % self.name)
time.sleep(0.1) #线程Thread-1执行到这里发生了阻塞,此时线程Thread-2已经运行起来了,因此抢到了A锁
mutexA.acquire() #线程Thread-1再想抢A锁时A锁已经在线程Thread-2手里
print(‘%s 拿到了A锁‘ % self.name)
mutexA.release()
mutexB.release()
if __name__ == ‘__main__‘:
for i in range(10):
t=MyThread()
t.start()
运行结果:
Thread-1 拿到了A锁
Thread-1 拿到了B锁
Thread-1 拿到了B锁
Thread-2 拿到了A锁
解决方法,递归锁,在Python中为了支持在同一线程中多次请求同一资源,python提供了可重入锁RLock。
这个RLock内部维护着一个Lock和一个counter变量,counter记录了acquire的次数,从而使得资源可以被多次require。
直到一个线程所有的acquire都被release,其他的线程才能获得资源。上面的例子如果使用RLock代替Lock,则不会发生死锁。
二者的区别是:递归锁可以连续acquire多次,而互斥锁只能acquire一次
from threading import Thread,Lock,RLock
import time
mutexA=mutexB=RLock() #这里实际还是一把锁,只是这样写下面的代码就不用变动了
#一个线程拿到锁,counter加1,该线程内又碰到加锁的情况,则counter继续加1,这期间所有其他线程都只能等待,等待该线程释放所有锁,即counter递减到0为止
class MyThread(Thread):
def run(self):
self.f1()
self.f2()
def f1(self):
mutexA.acquire()
print(‘%s 拿到了A锁‘ %self.name)
mutexB.acquire()
print(‘%s 拿到了B锁‘ % self.name)
mutexB.release() #1
mutexA.release() #0
def f2(self):
mutexB.acquire()
print(‘%s 拿到了B锁‘ % self.name)
time.sleep(0.1)
mutexA.acquire()
print(‘%s 拿到了A锁‘ % self.name)
mutexA.release()
mutexB.release()
if __name__ == ‘__main__‘:
for i in range(10):
t=MyThread()
t.start()
标签:重入 == 结果 read self 请求 run UI 可重入锁
原文地址:http://blog.51cto.com/dzm911/2071429