日韩久久久精品,亚洲精品久久久久久久久久久,亚洲欧美一区二区三区国产精品 ,一区二区福利

Python簡單進程鎖代碼實例

系統 1755 0

先說說線程

在多線程中,為了保證共享資源的正確性,我們常常會用到線程同步技術.
將一些敏感操作變成原子操作,保證同一時刻多個線程中只有一個線程在執行這個原子操作。
我最常用的是互斥鎖,也稱獨占鎖。其次還有讀寫鎖,信號量,條件變量等。
除此之外,我們在進程間通信時會用到信號,向某一個進程發送信號,該進程中設置信號處理函數,然后當該進程收到信號時,執行某些操作。
其實在線程中,也可以接受信號,利用這種機制,我們也可以用來實現線程同步。更多信息見 //www.jb51.net/article/64977.htm

再說說進程

進程里我們通過一些進程間通信方式,可以實現進程間的同步。
最近我遇到的一個情況是,某采集系統進程池中很多進程會向同一個日志文件中打印日志,如果通過進程間通信實現,比較麻煩。
還有一種辦法,如果采用共享內存的方式,不同的進程分別將日志消息通過共享內存放入一個線程安全的隊列中,再建立一個進程負責專門打印日志,這樣也可以保證不被大亂,
保證日志的正確性,但代碼量也很多阿。
還有一種辦法,在共享內存中設置一個互斥鎖,所有進程共享。
如果能像線程一樣,有一個簡單的互斥鎖,用的時候只要加鎖,就能實現進程間的互斥就好了。之前對文件加鎖,也有些印象,于是我用它實現了一個進程間的互斥鎖

            
#coding=utf-8 
 
""" 
Process mutex lock. 
Actually it is implemented by file lock. 
""" 
 
import fcntl 
 
class ProcessLock(object): 
 
    __lockfd = None 
 
    @staticmethod 
    def lock(): 
        ProcessLock.__lockfd = open(__file__, 'a+') 
        fcntl.flock(ProcessLock.__lockfd, fcntl.LOCK_EX) 
 
    @staticmethod 
    def unlock(): 
        fcntl.flock(ProcessLock.__lockfd, fcntl.LOCK_UN) 

          


加鎖? ProcessLock.lock()
釋放 ProcessLock.unlock()
非常簡單使用,有興趣的朋友可以試一試。


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對您有幫助就好】

您的支持是博主寫作最大的動力,如果您喜歡我的文章,感覺我的文章對您有幫助,請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長會非常 感謝您的哦?。?!

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 天镇县| 巫溪县| 扬中市| 平顶山市| 巴林右旗| 保定市| 剑川县| 渝中区| 恩施市| 镇平县| 凤翔县| 高青县| 年辖:市辖区| 津市市| 遂宁市| 青河县| 新竹县| 云和县| 清徐县| 湛江市| 图片| 平阳县| 石嘴山市| 富源县| 四平市| 法库县| 多伦县| 吉隆县| 松江区| 中山市| 章丘市| 阿城市| 永州市| 星子县| 云阳县| 报价| 绥江县| 清苑县| 岳西县| 民县| 桂阳县|