這篇文章主要介紹了Python線程之如何解決共享變量問(wèn)題，掐滅問(wèn)我們學(xué)習(xí)了銀行轉(zhuǎn)賬的這個(gè)場(chǎng)景，本文解決上次多個(gè)線程的操作都更改了amount變量導(dǎo)致運(yùn)行結(jié)果不對(duì)的問(wèn)題,需要的朋友可以參考一下

前面提到了銀行轉(zhuǎn)賬這個(gè)場(chǎng)景，展示了一個(gè)比較耗時(shí)的轉(zhuǎn)賬操作。

這篇繼續(xù)轉(zhuǎn)帳，下面展示一段程序，多個(gè)線程的操作都更改了amount變量導(dǎo)致運(yùn)行結(jié)果不對(duì)的問(wèn)題。

前文說(shuō)了轉(zhuǎn)賬問(wèn)題

下面展示另一種轉(zhuǎn)賬的方式：

import random
import threading
import datetime
import time

xuewei = {'balance': 157}


# amount為負(fù)數(shù)即是轉(zhuǎn)出金額
def transfer(money):
? ? name = threading.current_thread().getName()
? ? print("%s 給xuewei轉(zhuǎn)賬 %s " % (name, money))
? ? xuewei['balance'] += money
? ? print("xuewei賬戶(hù)余額：", xuewei['balance'])


lists = [-7, 20, -20, 7] ?# 4次轉(zhuǎn)賬的數(shù)額，負(fù)數(shù)為學(xué)委的賬戶(hù)轉(zhuǎn)出，正數(shù)為他人轉(zhuǎn)入。
# 創(chuàng)建4個(gè)任務(wù)給學(xué)委轉(zhuǎn)賬上面lists的金額
threads = []
for i in range(4):
? ? amount = lists[i]
? ? name = "t-" + str(i)
? ? print("%s 計(jì)劃轉(zhuǎn)賬 %s" % (name, amount))
? ? mythread = threading.Thread(name=name, target=lambda: transfer(amount))
? ? threads.append(mythread)

# 開(kāi)始轉(zhuǎn)賬
for t in threads:
? ? t.start()

# 等待3秒讓上面的轉(zhuǎn)賬任務(wù)都完成，我們?cè)诳纯促~戶(hù)余額
time.sleep(3)
print("-" * 16)
print("學(xué)委賬戶(hù)余額：", xuewei['balance'])

這里啟動(dòng)了4個(gè)線程，每個(gè)線程內(nèi)有個(gè)lambda表達(dá)式，分別于學(xué)委的賬戶(hù)進(jìn)行轉(zhuǎn)賬，但是最后結(jié)果是185. 而不是157.

下面是運(yùn)行結(jié)果：

PS: 這只是一種運(yùn)行結(jié)果。多線程的運(yùn)行結(jié)果不是永遠(yuǎn)一樣的。

如何解決這個(gè)問(wèn)題？

觀測(cè)結(jié)果我們發(fā)先amount只保留了最后一個(gè)值。

好，下面改造一下：

import random
import threading
import datetime
import time

xuewei = {'balance': 157}

lists = [-7, 20, -20, 7] ?# 4次轉(zhuǎn)賬的數(shù)額，負(fù)數(shù)為學(xué)委的賬戶(hù)轉(zhuǎn)出，正數(shù)為他人轉(zhuǎn)入。


def transfer(amount):
? ? name = threading.current_thread().getName()
? ? print("%s 給xuewei轉(zhuǎn)賬 %s " % (name,amount))
? ? xuewei['balance'] += amount
? ? print("xuewei賬戶(hù)余額：", xuewei['balance'])


# 創(chuàng)建4個(gè)任務(wù)給學(xué)委轉(zhuǎn)賬上面lists的金額
for i in range(4):
? ? amount = lists[i]
? ? name = str(i)
? ? # mythread = threading.Thread(name=name, target=lambda: transfer(amount))
? ? def event():
? ? ? ? print("%s 計(jì)劃轉(zhuǎn)賬 %s" % (name, amount))
? ? ? ? transfer(amount)
? ? mythread = threading.Thread(name=name, target=event)
? ? mythread.start()


# 等待3秒讓上面的轉(zhuǎn)賬任務(wù)都完成，我們?cè)诳纯促~戶(hù)余額
time.sleep(3)
print("-" * 16)
print("學(xué)委賬戶(hù)余額：", xuewei['balance'])

學(xué)委這里加了一個(gè)event函數(shù)，把轉(zhuǎn)賬計(jì)劃打印出來(lái)。

從下面的一次運(yùn)行結(jié)果看，event函數(shù)的輸出結(jié)果沒(méi)錯(cuò)，所有”計(jì)劃轉(zhuǎn)賬“金額都如預(yù)期[-7, 20, -20 7]。問(wèn)題是transfer函數(shù)再多線程執(zhí)行的時(shí)候，我們發(fā)現(xiàn)amount被多線程競(jìng)爭(zhēng)修改了：

用戶(hù)0轉(zhuǎn)賬金額變成20
用戶(hù)1轉(zhuǎn)賬金額變成-20
用戶(hù)2轉(zhuǎn)賬金額變成7
用戶(hù)3轉(zhuǎn)賬金額變成7

也就是說(shuō)，amount被后面的線程修改了，但是前面線程還沒(méi)有執(zhí)行完。
用戶(hù)0應(yīng)該轉(zhuǎn)賬-7的，中間還沒(méi)有執(zhí)行完畢，結(jié)果被線程1修改了amount為20，用戶(hù)0繼續(xù)執(zhí)行轉(zhuǎn)賬，余額變成177. 其他依次推理。

amount這個(gè)變量被多個(gè)線程競(jìng)爭(zhēng)修改了，這個(gè)就是程序的共享變量。

到底如何解決？

方法非常簡(jiǎn)單：直接干掉共享變量。

下面就是消除共享變量的方法： 讓共享變成每個(gè)線程訪問(wèn)獨(dú)立運(yùn)行空間

所以代碼改動(dòng)如下：

import random
import threading
import datetime
import time

xuewei = {'balance': 157}

lists = [-7, 20, -20, 7] ?# 4次轉(zhuǎn)賬的數(shù)額，負(fù)數(shù)為學(xué)委的賬戶(hù)轉(zhuǎn)出，正數(shù)為他人轉(zhuǎn)入。
# 我們不要依賴(lài)amount變量了
def transfer():
? ? name = threading.current_thread().getName()
? ? xuewei['balance'] += lists[int(name)] #通過(guò)線程名字來(lái)獲取對(duì)應(yīng)金額
? ? print("xuewei賬戶(hù)余額：", xuewei['balance'])

# 創(chuàng)建4個(gè)任務(wù)給學(xué)委轉(zhuǎn)賬上面lists的金額
threads = []
for i in range(4):
? ? amount = lists[i]
? ? name = str(i)
? ? print("%s 計(jì)劃轉(zhuǎn)賬 %s" % (name, amount))
? ? # mythread = threading.Thread(name=name, target=lambda: transfer())
? ? def event():
? ? ? ? transfer()
? ? mythread = threading.Thread(name=name, target=event)
? ? threads.append(mythread)

# 開(kāi)始轉(zhuǎn)賬
for t in threads:
? ? t.start()

# 等待3秒讓上面的轉(zhuǎn)賬任務(wù)都完成，我們?cè)诳纯促~戶(hù)余額
time.sleep(3)
print("-" * 16)
print("學(xué)委賬戶(hù)余額：", xuewei['balance'])

運(yùn)行結(jié)果如下：