快捷導(dǎo)航

Python多線程編程（六）：可重入鎖RLock

更新時(shí)間：2015年04月05日 11:39:52 投稿：junjie

這篇文章主要介紹了Python多線程編程（六）：可重入鎖RLock,本文直接給出使用實(shí)例,然后講解如何使用RLock避免死鎖,需要的朋友可以參考下

考慮這種情況：如果一個(gè)線程遇到鎖嵌套的情況該怎么辦，這個(gè)嵌套是指當(dāng)我一個(gè)線程在獲取臨界資源時(shí)，又需要再次獲取。

根據(jù)這種情況，代碼如下：

''' 

Created on 2012-9-8 

@author: walfred 

@module: thread.ThreadTest6 

'''  

import threading  

import time  

counter = 0  

mutex = threading.Lock()  

class MyThread(threading.Thread):  

    def __init__(self):  

        threading.Thread.__init__(self)  

    def run(self):  

        global counter, mutex  

        time.sleep(1);  

        if mutex.acquire():  

            counter += 1  

            print "I am %s, set counter:%s" % (self.name, counter)  

            if mutex.acquire():  

                counter += 1  

                print "I am %s, set counter:%s" % (self.name, counter)  

                mutex.release()  

            mutex.release()  

if __name__ == "__main__":  

    for i in range(0, 200):  

        my_thread = MyThread()  

        my_thread.start()

這種情況的代碼運(yùn)行情況如下：

復(fù)制代碼代碼如下:

I am Thread-1, set counter:1

之后就直接掛起了，這種情況形成了最簡單的死鎖。

那有沒有一種情況可以在某一個(gè)線程使用互斥鎖訪問某一個(gè)競爭資源時(shí)，可以再次獲取呢？在Python中為了支持在同一線程中多次請求同一資源，python提供了“可重入鎖”：threading.RLock。這個(gè)RLock內(nèi)部維護(hù)著一個(gè)Lock和一個(gè)counter變量，counter記錄了acquire的次數(shù)，從而使得資源可以被多次require。直到一個(gè)線程所有的acquire都被release，其他的線程才能獲得資源。上面的例子如果使用RLock代替Lock，則不會(huì)發(fā)生死鎖：

代碼只需將上述的：

復(fù)制代碼代碼如下:

mutex = threading.Lock()

替換成：

復(fù)制代碼代碼如下:

mutex = threading.RLock()

即可。

您可能感興趣的文章: