码迷,mamicode.com
首页 > 编程语言 > 详细

Python Day10

时间:2018-02-12 23:01:57      阅读:202      评论:0      收藏:0      [点我收藏+]

标签:重入   ==   结果   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()

Python Day10

标签:重入   ==   结果   read   self   请求   run   UI   可重入锁   

原文地址:http://blog.51cto.com/dzm911/2071429

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!