在Python中,可以使用共享變量來實(shí)現(xiàn)雙線程之間的數(shù)據(jù)傳遞。下面是一個(gè)簡單的例子:
import threading
# 創(chuàng)建一個(gè)共享變量
shared_variable = 0
# 創(chuàng)建一個(gè)鎖來保護(hù)共享變量的訪問
lock = threading.Lock()
# 定義一個(gè)線程函數(shù),用于增加共享變量的值
def increase():
global shared_variable
for _ in range(1000000):
# 獲取鎖
lock.acquire()
shared_variable += 1
# 釋放鎖
lock.release()
# 定義一個(gè)線程函數(shù),用于減少共享變量的值
def decrease():
global shared_variable
for _ in range(1000000):
# 獲取鎖
lock.acquire()
shared_variable -= 1
# 釋放鎖
lock.release()
# 創(chuàng)建兩個(gè)線程
t1 = threading.Thread(target=increase)
t2 = threading.Thread(target=decrease)
# 啟動(dòng)線程
t1.start()
t2.start()
# 等待線程結(jié)束
t1.join()
t2.join()
# 輸出共享變量的值
print(shared_variable)
在上述代碼中,我們創(chuàng)建了一個(gè)共享變量shared_variable
和一個(gè)鎖lock
。然后我們定義了兩個(gè)線程函數(shù)increase
和decrease
,分別用于增加和減少共享變量的值。在每個(gè)線程函數(shù)中,我們首先獲取鎖,然后對(duì)共享變量進(jìn)行修改,最后釋放鎖。這樣可以確保每次只有一個(gè)線程在訪問共享變量,避免了數(shù)據(jù)競爭的問題。
最后,我們創(chuàng)建了兩個(gè)線程t1
和t2
,并分別啟動(dòng)它們。然后使用join
方法等待兩個(gè)線程結(jié)束,并輸出最終的共享變量的值。