一、共享變量

共享變量：當(dāng)多個(gè)線程訪問(wèn)同一個(gè)變量的時(shí)候。會(huì)產(chǎn)生共享變量的問(wè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)槲覀児蚕碜兞苛耍瑫r(shí)對(duì)變量進(jìn)行了操作，程序并不是原子的。

2.解決方案：使用“鎖”，“信號(hào)燈”

（1）鎖lock：是一個(gè)標(biāo)志，表示一個(gè)線程在占用一些資源。

使用方式：先上鎖，然后使用共享資源，放心的使用，最后再釋放鎖，即釋放了這個(gè)變量。

鎖哪個(gè)：哪個(gè)資源需要共享，那么就鎖誰(shuí)

            
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()# 注意千萬(wàn)不要忘了釋放鎖
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ù)料的加減的順序無(wú)所謂，但最后是零和游戲，但是上面的那個(gè)例子，都也是加減順序無(wú)所謂，但是有一點(diǎn)要知道會(huì)存在同時(shí)對(duì)變量的內(nèi)存使用的情況，這就存在內(nèi)存被錯(cuò)寫(xiě)的風(fēng)險(xiǎn)，所以最后結(jié)果不對(duì)，上面的不是零和游戲。

（2）線程的安全問(wèn)題：

如果一個(gè)資源、變量，他對(duì)于多線程來(lái)講，不用加鎖，也不會(huì)引起任何問(wèn)題，則稱(chēng)為線程安全；線程不安全的變量類(lèi)型：list\set\dict;線程安全的變量類(lèi)型：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í)有所幫助，也希望大家多多支持腳本之家。