python 加锁_Python 共享变量加锁、释放详解
一、共享變量
共享變量:當多個線程訪問同一個變量的時候。會產生共享變量的問題。
例子:
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
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
總結
以上是生活随笔為你收集整理的python 加锁_Python 共享变量加锁、释放详解的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: opencv python3 找图片色块
- 下一篇: 全局描述符表(GDT)——《x86汇编语