一、共享變量
共享變量:當多個線程訪問同一個變量的時候。會產生共享變量的問題。
例子:
import threading sum = 0 loopSum = 1000000 def myAdd(): global sum, loopSum for i in range(1, loopSum): sum += 1 def myMinu(): global sum, loopSum for i in range(1, loopSum): sum -= 1 if __name__ == "__main__": print("Dont,,,,,,,{0}".format(sum)) t1 = threading.Thread(target = myAdd, args = ()) t2 = threading.Thread(target = myMinu, args = ()) t1.start() t2.start() t1.join() t2.join() print("Done,,,,,,{0}".format(sum))
正如上面的結果可以看出:并不是我們期望的0,而是-286705,這就是因為我們共享變量了,同時對變量進行了操作,程序并不是原子的。
2.解決方案:使用“鎖”,“信號燈”
(1)鎖lock:是一個標志,表示一個線程在占用一些資源。
使用方式:先上鎖,然后使用共享資源,放心的使用,最后再釋放鎖,即釋放了這個變量。
鎖哪個:哪個資源需要共享,那么就鎖誰
import threading sum = 0 loopSum = 1000000 lock = threading.Lock() # 先生成一個鎖的實例 def myAdd(): global sum, loopSum for i in range(1, loopSum): lock.acquire()# 這里申請了一把鎖 sum += 1 lock.release()# 注意千萬不要忘了釋放鎖 def myMinu(): global sum, loopSum for i in range(1, loopSum): lock.acquire() sum -= 1 lock.release() if __name__ == "__main__": print("Done,,,,,,,{0}".format(sum)) t1 = threading.Thread(target = myAdd, args = ()) t2 = threading.Thread(target = myMinu, args = ()) t1.start() t2.start() t1.join() t2.join() print("Done,,,,,,{0}".format(sum))
正如我們所預料的加減的順序無所謂,但最后是零和游戲,但是上面的那個例子,都也是加減順序無所謂,但是有一點要知道會存在同時對變量的內存使用的情況,這就存在內存被錯寫的風險,所以最后結果不對,上面的不是零和游戲。
(2)線程的安全問題:
如果一個資源、變量,他對于多線程來講,不用加鎖,也不會引起任何問題,則稱為線程安全;線程不安全的變量類型:list\set\dict;線程安全的變量類型:queue
二、源碼
d25_1_shared_variable_and_lock.py
https://github.com/ruigege66/Python_learning/blob/master/d25_1_shared_variable_and_lock.py
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
更多文章、技術交流、商務合作、聯系博主
微信掃碼或搜索:z360901061

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