有個概念叫做線程局部變量,一般我們對多線程中的全局變量都會加鎖處理,這種變量是共享變量,每個線程都可以讀寫變量,為了保持同步我們會做枷鎖處理。
但是有些變數初始化以後,我們只想讓他們在每個執行緒中一直存在,相當於一個執行緒內的共享變量,執行緒之間又是隔離的,就是局部變數。 python threading模組中就提供了這麼一個類,叫做local。 (推薦學習:Python影片教學)
使用局部變數的時候,需要傳遞參數,例如有這樣一個例子,程式需要處理客戶申請,每來一個客戶,就新開一個線程進行處理,而客戶有姓名、年齡、性別等屬性(參數),如果都需要傳遞參數的話很繁瑣。 Python提供了threading.local模組,方便我們實作執行緒局部變數的傳遞。直接看下面的範例:
# /usr/bin/env python # coding:utf-8 import threading # Threading.local对象 ThreadLocalHelper = threading.local() lock = threading.RLock() class MyTheadEx(threading.Thread): def __init__(self, threadName, name, age, sex): super(MyTheadEx, self).__init__(name=threadName) self.__name = name self.__age = age self.__sex = sex def run(self): global ThreadLocalHelper ThreadLocalHelper.ThreadName = self.name ThreadLocalHelper.Name = self.__name ThreadLocalHelper.Age = self.__age ThreadLocalHelper.Sex = self.__sex MyTheadEx.ThreadPoc() # 线程处理函数 @staticmethod def ThreadPoc(): lock.acquire() try: print 'Thread={id}'.format(id=ThreadLocalHelper.ThreadName) print 'Name={name}'.format(name=ThreadLocalHelper.Name) print 'Age={age}'.format(age=ThreadLocalHelper.Age) print 'Sex={sex}'.format(sex=ThreadLocalHelper.Sex) print '----------' finally: lock.release() if __name__ == '__main__': Tom = {'Name': 'tom', 'Age': 20, 'Sex': 'man'} xiaohua = {'Name': 'xiaohua', 'Age': 18, 'Sex': 'woman'} Andy = {'Name': 'Andy', 'Age': 40, 'Sex': 'man'} T = (Tom, xiaohua, Andy) threads = [] for i in range(len(T)): t = MyTheadEx(threadName='id_{0}'.format(i), name=T[i]['Name'], age=T[i]['Age'], sex=T[i]['Sex']) threads.append(t) for i in range(len(threads)): threads[i].start() for i in range(len(threads)): threads[i].join() print 'All Done!!!'
可見,每個執行緒都可以對threading.local物件進行讀寫,且互相不干擾。合理使用threading.local可以大幅簡化程式碼邏輯,同時確保各個子執行緒的資料安全。 Threading.local最大的用處就是HTTP請求時綁定使用者的訊息,這樣每個使用者執行緒可以非常方便存取各自的資源而互不干擾。
更多Python相關技術文章,請造訪Python教學欄位學習!
以上是python怎麼定義線程局部變數的詳細內容。更多資訊請關注PHP中文網其他相關文章!