一、共享變量
共享變量:當多個線程訪問同一個變量的時候。會產生共享變量的問題。
例子:
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元等您想捐的金額吧,狠狠點擊下面給點支持吧,站長非常感激您!手機微信長按不能支付解決辦法:請將微信支付二維碼保存到相冊,切換到微信,然后點擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對您有幫助就好】元

