国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 編程 > Python > 正文

Python簡單進程鎖代碼實例

2020-02-23 00:53:22
字體:
來源:轉載
供稿:網友

先說說線程

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

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 大竹县| 吉木萨尔县| 旅游| 根河市| 沭阳县| 冀州市| 灵台县| 桐庐县| 东至县| 西城区| 罗城| 佛坪县| 延安市| 勐海县| 芦山县| 扶绥县| 无棣县| 成安县| 京山县| 朝阳区| 阳泉市| 卫辉市| 西林县| 洛阳市| 合作市| 景宁| 沅江市| 海林市| 井研县| 永平县| 永宁县| 庆阳市| 永定县| 洪洞县| 石河子市| 湟源县| 乌苏市| 榆社县| 耿马| 婺源县| 德化县|