在Python中,可以使用多線程模塊threading
來實現多線程數據交互。以下是一個簡單的示例:
import threading
def thread_a():
global data
for i in range(5):
data += 1
print("Thread A: ", data)
def thread_b():
global data
for i in range(5):
data -= 1
print("Thread B: ", data)
# 共享的數據
data = 0
# 創建線程
thread1 = threading.Thread(target=thread_a)
thread2 = threading.Thread(target=thread_b)
# 啟動線程
thread1.start()
thread2.start()
# 等待線程結束
thread1.join()
thread2.join()
在上面的示例中,我們創建了兩個線程thread_a
和thread_b
,它們共享一個全局變量data
。每個線程都對data
進行操作,然后打印出結果。在主線程中,我們使用thread1.start()
和thread2.start()
來啟動這兩個線程,然后使用thread1.join()
和thread2.join()
來等待線程結束。
需要注意的是,多線程數據交互可能會出現競態條件,需要使用鎖或其他同步機制來保證數據的正確性。