先說說線程
在多線程中,為了保證共享資源的正確性,我們常常會用到線程同步技術.
將一些敏感操作變成原子操作,保證同一時刻多個線程中只有一個線程在執行這個原子操作。
我最常用的是互斥鎖,也稱獨占鎖。其次還有讀寫鎖,信號量,條件變量等。
除此之外,我們在進程間通信時會用到信號,向某一個進程發送信號,該進程中設置信號處理函數,然后當該進程收到信號時,執行某些操作。
其實在線程中,也可以接受信號,利用這種機制,我們也可以用來實現線程同步。更多信息見 //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元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元
