#!/usr/bin/env python3
# -*- coding:utf-8 -*-
# Author: LiveEveryDay
 
 
import threading
 
total = 0
 
 
def update_total(amount):
    global total
    total += amount
    print(total)
 
 
if __name__ == '__main__':
    for i in range(10):
        my_thread = threading.Thread(target=update_total, args=(5,))
        my_thread.start()
 
''' ------ Running Results ------
510
15
20
25
30
3540
45
50
'''

如果往以上代碼添加 time.sleep 函數(shù)并給出不同長度的時間，可能會讓這個例子更有意思。無論如何，這里的問題是，一個線程可能已經(jīng)調(diào)用 update_total 函數(shù)并且還沒有更新完成，此時另一個線程也有可能調(diào)用它并且嘗試更新內(nèi)容。根據(jù)操作執(zhí)行順序的不同，該值可能只被增加一次。

給它添加鎖后：

方式一：使用try/finally，確保鎖肯定會被釋放。

#!/usr/bin/env python3
# -*- coding:utf-8 -*-
# Author: LiveEveryDay
 
 
import threading
 
total = 0
lock = threading.Lock()
 
 
def update_total(amount):
    global total
    lock.acquire()
    try:
        total += amount
    finally:
        print(total)
        lock.release()
 
 
if __name__ == '__main__':
    for i in range(10):
        my_thread = threading.Thread(target=update_total, args=(5,))
        my_thread.start()
 
''' ------ Running Results ------
5
10
15
20
25
30
35
40
45
50
'''

如上，在我們做任何處理之前就獲取鎖。然后嘗試更新 total 的值，最后打印出 total 的當前值并釋放鎖。

方式二：with語句避免使用try/finally。

事實上，我們可以使用 Python 的 with 語句避免使用 try/finally 這種較為繁瑣的語句：

#!/usr/bin/env python3
# -*- coding:utf-8 -*-
# Author: LiveEveryDay
 
 
import threading
 
total = 0
lock = threading.Lock()
 
 
def update_total(amount):
    global total
    with lock:
        total += amount
        print(total)
 
 
if __name__ == '__main__':
    for i in range(10):
        my_thread = threading.Thread(target=update_total, args=(5,))
        my_thread.start()
 
''' ------ Running Results ------
5
10
15
20
25
30
35
40
45
50
'''