电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Python讀寫鎖實現(xiàn)實現(xiàn)代碼解析

瀏覽:117日期:2022-07-04 08:56:50

起步

Python 提供的多線程模型中并沒有提供讀寫鎖,讀寫鎖相對于單純的互斥鎖,適用性更高,可以多個線程同時占用讀模式的讀寫鎖,但是只能一個線程占用寫模式的讀寫鎖。

通俗點說就是當沒有寫鎖時,就可以加讀鎖且任意線程可以同時加;而寫鎖只能有一個線程,且必須在沒有讀鎖時才能加上。

簡單的實現(xiàn)

import threadingclass RWlock(object): def __init__(self): self._lock = threading.Lock() self._extra = threading.Lock() self.read_num = 0 def read_acquire(self): with self._extra: self.read_num += 1 if self.read_num == 1:self._lock.acquire() def read_release(self): with self._extra: self.read_num -= 1 if self.read_num == 0:self._lock.release() def write_acquire(self): self._lock.acquire() def write_release(self): self._lock.release()

這是讀寫鎖的一個簡單的實現(xiàn),self.read_num 用來保存獲得讀鎖的線程數(shù),這個屬性屬于臨界區(qū),對其操作也要加鎖,所以這里需要一個保護內部數(shù)據(jù)的額外的鎖 self._extra 。

但是這個鎖是不公平的。理想情況下,線程獲得所的機會應該是一樣的,不管線程是讀操作還是寫操作。而從上述代碼可以看到,讀請求都會立即設置 self.read_num += 1,不管有沒有獲得鎖,而寫請求想要獲得鎖還得等待 read_num 為 0 。

所以這個就造成了只有鎖沒有被占用或者沒有讀請求時,可以獲得寫權限。我們應該想辦法避免讀模式鎖長期占用。

讀寫鎖的優(yōu)先級

讀寫鎖也有分 讀優(yōu)先 和 寫優(yōu)先。上面的代碼就屬于讀優(yōu)先。

如果要改成寫優(yōu)先,那就換成去記錄寫線程的引用計數(shù),讀和寫在同時競爭時,可以讓寫線程增加寫的計數(shù),這樣可使讀線程的讀鎖一直獲取不到, 因為讀線程要先判斷寫的引用計數(shù),若不為0,則等待其為 0,然后進行讀。這部分代碼不羅列了。

但這樣顯然不夠靈活。我們不需要兩個相似的讀寫鎖類。我們希望重構我們代碼,使它更強大。

改進

為了能夠滿足自定義優(yōu)先級的讀寫鎖,要記錄等待的讀寫線程數(shù),并且需要兩個條件 threading.Condition 用來處理哪方優(yōu)先的通知。計數(shù)引用可以擴大語義:正數(shù):表示正在讀操作的線程數(shù),負數(shù):表示正在寫操作的線程數(shù)(最多-1)

在獲取讀操作時,先然后判斷時候有等待的寫線程,沒有,進行讀操作,有,則等待讀的計數(shù)加 1 后等待 Condition 通知;等待讀的計數(shù)減 1,計數(shù)引用加 1,繼續(xù)讀操作,若條件不成立,循環(huán)等待;

在獲取寫操作時,若鎖沒有被占用,引用計數(shù)減 1,若被占用,等待寫線程數(shù)加 1,等待寫條件 Condition 的通知。

讀模式和寫模式的釋放都是一樣,需要根據(jù)判斷去通知對應的 Condition:

class RWLock(object): def __init__(self): self.lock = threading.Lock() self.rcond = threading.Condition(self.lock) self.wcond = threading.Condition(self.lock) self.read_waiter = 0 # 等待獲取讀鎖的線程數(shù) self.write_waiter = 0 # 等待獲取寫鎖的線程數(shù) self.state = 0 # 正數(shù):表示正在讀操作的線程數(shù) 負數(shù):表示正在寫操作的線程數(shù)(最多-1) self.owners = [] # 正在操作的線程id集合 self.write_first = True # 默認寫優(yōu)先,F(xiàn)alse表示讀優(yōu)先 def write_acquire(self, blocking=True): # 獲取寫鎖只有當 me = threading.get_ident() with self.lock: while not self._write_acquire(me):if not blocking: return Falseself.write_waiter += 1self.wcond.wait()self.write_waiter -= 1 return True def _write_acquire(self, me): # 獲取寫鎖只有當鎖沒人占用,或者當前線程已經(jīng)占用 if self.state == 0 or (self.state < 0 and me in self.owners): self.state -= 1 self.owners.append(me) return True if self.state > 0 and me in self.owners: raise RuntimeError(’cannot recursively wrlock a rdlocked lock’) return False def read_acquire(self, blocking=True): me = threading.get_ident() with self.lock: while not self._read_acquire(me):if not blocking: return Falseself.read_waiter += 1self.rcond.wait()self.read_waiter -= 1 return True def _read_acquire(self, me): if self.state < 0: # 如果鎖被寫鎖占用 return False if not self.write_waiter: ok = True else: ok = me in self.owners if ok or not self.write_first: self.state += 1 self.owners.append(me) return True return False def unlock(self): me = threading.get_ident() with self.lock: try:self.owners.remove(me) except ValueError:raise RuntimeError(’cannot release un-acquired lock’) if self.state > 0:self.state -= 1 else:self.state += 1 if not self.state:if self.write_waiter and self.write_first: # 如果有寫操作在等待(默認寫優(yōu)先) self.wcond.notify()elif self.read_waiter: self.rcond.notify_all()elif self.write_waiter: self.wcond.notify() read_release = unlock write_release = unlock

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網(wǎng)。

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 回转支承-转盘轴承-回转驱动生产厂家-洛阳隆达轴承有限公司 | 光环国际-新三板公司_股票代码:838504 | 高速混合机_锂电混合机_VC高效混合机-无锡鑫海干燥粉体设备有限公司 | 恒压供水控制柜|无负压|一体化泵站控制柜|PLC远程调试|MCGS触摸屏|自动控制方案-联致自控设备 | PCB接线端子_栅板式端子_线路板连接器_端子排生产厂家-置恒电气 喷码机,激光喷码打码机,鸡蛋打码机,手持打码机,自动喷码机,一物一码防伪溯源-恒欣瑞达有限公司 假肢-假肢价格-假肢厂家-河南假肢-郑州市力康假肢矫形器有限公司 | 意大利Frascold/富士豪压缩机_富士豪半封闭压缩机_富士豪活塞压缩机_富士豪螺杆压缩机 | 郑州爱婴幼师学校_专业幼师培训_托育师培训_幼儿教育培训学校 | 消泡剂-水处理消泡剂-涂料消泡剂-切削液消泡剂价格-东莞德丰消泡剂厂家 | 郑州水质检测中心_井水检测_河南废气检测_河南中环嘉创检测 | 整合营销推广|营销网络推广公司|石家庄网站优化推广公司|智营销 好物生环保网、环保论坛 - 环保人的学习交流平台 | 西安展台设计搭建_西安活动策划公司_西安会议会场布置_西安展厅设计西安旭阳展览展示 | LED显示屏_LED屏方案设计精准报价专业安装丨四川诺显科技 | 北京网站建设首页,做网站选【优站网】,专注北京网站建设,北京网站推广,天津网站建设,天津网站推广,小程序,手机APP的开发。 | 齿辊分级破碎机,高低压压球机,立式双动力磨粉机-郑州长城冶金设备有限公司 | 网站建设,北京网站建设,北京网站建设公司,网站系统开发,北京网站制作公司,响应式网站,做网站公司,海淀做网站,朝阳做网站,昌平做网站,建站公司 | 杭州中央空调维修_冷却塔/新风机柜/热水器/锅炉除垢清洗_除垢剂_风机盘管_冷凝器清洗-杭州亿诺能源有限公司 | 酒万铺-酒水招商-酒水代理| 气力输送_输送机械_自动化配料系统_负压吸送_制造主力军江苏高达智能装备有限公司! | 热缩管切管机-超声波切带机-织带切带机-无纺布切布机-深圳市宸兴业科技有限公司 | 森旺-A级防火板_石英纤维板_不燃抗菌板装饰板_医疗板 | 骨灰存放架|骨灰盒寄存架|骨灰架厂家|智慧殡葬|公墓陵园管理系统|网上祭奠|告别厅智能化-厦门慈愿科技 | 金刚网,金刚网窗纱,不锈钢网,金刚网厂家- 河北萨邦丝网制品有限公司 | 运动木地板价格,篮球馆体育运动木地板生产厂家_欧氏地板 | 斗式提升机,斗式提升机厂家-淄博宏建机械有限公司 | 紫外线老化试验箱_uv紫外线老化试验箱价格|型号|厂家-正航仪器设备 | 热处理炉-退火炉-回火炉设备厂家-丹阳市电炉厂有限公司 | 安全,主动,被动,柔性,山体滑坡,sns,钢丝绳,边坡,防护网,护栏网,围栏,栏杆,栅栏,厂家 - 护栏网防护网生产厂家 | 钢制拖链生产厂家-全封闭钢制拖链-能源钢铝拖链-工程塑料拖链-河北汉洋机械制造有限公司 | 青岛球场围网,青岛车间隔离网,青岛机器人围栏,青岛水源地围网,青岛围网,青岛隔离栅-青岛晟腾金属制品有限公司 | 微动开关厂家-东莞市德沃电子科技有限公司 | 小型UV打印机-UV平板打印机-大型uv打印机-UV打印机源头厂家 |松普集团 | 有声小说,听书,听小说资源库-听世界网 | 不锈钢电动球阀_气动高压闸阀_旋塞疏水调节阀_全立阀门-来自温州工业阀门巨头企业 | 东莞爱加真空科技有限公司-进口真空镀膜机|真空镀膜设备|Polycold维修厂家 | 证券新闻,热播美式保罗1984第二部_腾讯1080p-仁爱影院 | 安全光栅|射频导纳物位开关|音叉料位计|雷达液位计|两级跑偏开关|双向拉绳开关-山东卓信机械有限公司 | 防渗土工膜|污水处理防渗膜|垃圾填埋场防渗膜-泰安佳路通工程材料有限公司 | 代办建筑资质升级-建筑资质延期就找上海国信启航 | 散热器-电子散热器-型材散热器-电源散热片-镇江新区宏图电子散热片厂家 | 挖掘机挖斗和铲斗生产厂家选择徐州崛起机械制造有限公司 | 安平县鑫川金属丝网制品有限公司,防风抑尘网,单峰防风抑尘,不锈钢防风抑尘网,铝板防风抑尘网,镀铝锌防风抑尘网 |