python线程如何实现数据共享?
最新回答
念颜洛
2024-11-27 05:38:31
Lock 是一种用于解决线程间资源共享冲突的机制。它允许同一时刻只有一个线程访问共享资源。例如，以下代码演示了如何使用 Lock 实现两个线程对全局变量 count 的安全操作。
python
from threading import Thread, Lock
count = 0
lock = Lock()
def increment():
global count
with lock:
for i in range(100000):
count += 1
def decrement():
global count
with lock:
for i in range(100000):
count -= 1
t1 = Thread(target=increment)
t2 = Thread(target=decrement)
t1.start()
t2.start()
t1.join()
t2.join()
print("Count = ", count)
Queue 用于线程间数据传递，它支持安全的 put 和 get 操作。下面是一个使用 Queue 实现多线程间任务共享的示例。
python
from threading import Thread
from queue import Queue
def worker(q):
while True:
task = q.get()
if task is None:
break
print("Processing task: ", task)
q = Queue()
t1 = Thread(target=worker, args=(q,))
t2 = Thread(target=worker, args=(q,))
t1.start()
t2.start()
for i in range(10):
q.put(i)
q.put(None)
q.put(None)
t1.join()
t2.join()
通过合理选择和使用 Lock 和 Queue，可以实现 Python 中线程间的高效数据共享和同步。
热门标签
