您好,登錄后才能下訂單哦!
一、共享變量
共享變量:當多個線程訪問同一個變量的時候。會產生共享變量的問題。
例子:
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
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。