以下是一个示例程序,其中多个线程向列表中添加相同数量的元素:
import threading
# 共享列表
my_list = []
# 锁对象
lock = threading.Lock()
# 添加元素的函数
def add_elements(num_elements):
global my_list
for i in range(num_elements):
# 获取锁
lock.acquire()
try:
# 向列表添加元素
my_list.append(i)
finally:
# 释放锁
lock.release()
# 创建线程
num_threads = 5
num_elements = 1000
threads = []
for _ in range(num_threads):
t = threading.Thread(target=add_elements, args=(num_elements,))
threads.append(t)
# 启动线程
for t in threads:
t.start()
# 等待所有线程完成
for t in threads:
t.join()
# 打印最终的列表元素数量
print(len(my_list))
在上面的示例中,我们创建了一个共享列表my_list
和一个锁对象lock
。每个线程都会调用add_elements()
函数,该函数使用锁来确保在添加元素时只有一个线程能访问列表。最后,我们等待所有线程完成,并打印最终的列表元素数量。
请注意,由于多个线程同时访问和修改共享数据,因此在并发编程中需要小心处理同步和互斥。使用锁可以确保在任何时候只有一个线程能够访问共享资源,从而避免数据竞争和不确定的结果。