您好,登錄后才能下訂單哦!
一、共享變量
共享變量:當(dāng)多個(gè)線程訪問同一個(gè)變量的時(shí)候。會(huì)產(chǎn)生共享變量的問題。
例子:
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))
正如上面的結(jié)果可以看出:并不是我們期望的0,而是-286705,這就是因?yàn)槲覀児蚕碜兞苛?,同時(shí)對(duì)變量進(jìn)行了操作,程序并不是原子的。
2.解決方案:使用“鎖”,“信號(hào)燈”
(1)鎖lock:是一個(gè)標(biāo)志,表示一個(gè)線程在占用一些資源。
使用方式:先上鎖,然后使用共享資源,放心的使用,最后再釋放鎖,即釋放了這個(gè)變量。
鎖哪個(gè):哪個(gè)資源需要共享,那么就鎖誰
import threading sum = 0 loopSum = 1000000 lock = threading.Lock() # 先生成一個(gè)鎖的實(shí)例 def myAdd(): global sum, loopSum for i in range(1, loopSum): lock.acquire()# 這里申請(qǐng)了一把鎖 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))
正如我們所預(yù)料的加減的順序無所謂,但最后是零和游戲,但是上面的那個(gè)例子,都也是加減順序無所謂,但是有一點(diǎn)要知道會(huì)存在同時(shí)對(duì)變量的內(nèi)存使用的情況,這就存在內(nèi)存被錯(cuò)寫的風(fēng)險(xiǎn),所以最后結(jié)果不對(duì),上面的不是零和游戲。
(2)線程的安全問題:
如果一個(gè)資源、變量,他對(duì)于多線程來講,不用加鎖,也不會(huì)引起任何問題,則稱為線程安全;線程不安全的變量類型: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
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持億速云。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。