Python中有多種方法可以實現多線程同步,以下是其中幾種常用的方法:
import threading
# 共享資源
shared_resource = 0
# 創建鎖
lock = threading.Lock()
# 線程函數
def thread_func():
global shared_resource
# 獲取鎖
lock.acquire()
try:
# 修改共享資源
shared_resource += 1
finally:
# 釋放鎖
lock.release()
import threading
# 共享資源
shared_resource = 0
# 創建條件
condition = threading.Condition()
# 線程函數
def thread_func():
global shared_resource
# 獲取條件鎖
with condition:
# 修改共享資源
shared_resource += 1
# 通知其他等待線程
condition.notify_all()
import threading
# 共享資源
shared_resource = 0
# 創建信號量
semaphore = threading.Semaphore(1)
# 線程函數
def thread_func():
global shared_resource
# 獲取信號量
semaphore.acquire()
try:
# 修改共享資源
shared_resource += 1
finally:
# 釋放信號量
semaphore.release()
這些方法都可以實現多線程的同步,具體選擇哪種方法取決于具體的應用場景和需求。