Python中的多线程可以通过共享全局变量或者使用共享内存来共享变量。以下是几种常见的方法:
import threading
global_var = 0
lock = threading.Lock()
def increment_global_var():
global global_var
with lock:
global_var += 1
threads = []
for _ in range(10):
t = threading.Thread(target=increment_global_var)
threads.append(t)
t.start()
for t in threads:
t.join()
print(global_var)
multiprocessing
模块中的Value
或者Array
来创建共享内存对象,多个线程可以同时访问和修改这些共享内存对象。import threading
from multiprocessing import Value
shared_var = Value('i', 0)
def increment_shared_var():
with shared_var.get_lock():
shared_var.value += 1
threads = []
for _ in range(10):
t = threading.Thread(target=increment_shared_var)
threads.append(t)
t.start()
for t in threads:
t.join()
print(shared_var.value)
无论使用哪种方法,都需要注意保护共享变量,避免多个线程同时修改导致数据不一致的问题。