如何在Python中将来自多个线程的同步数据写入csv文件

import threading
import csv

# 共享数据结构，用于存储线程处理的数据
data = []

# 创建锁对象
lock = threading.Lock()

# 线程函数，模拟数据处理
def process_data(thread_id):
    global data, lock
    # 数据处理逻辑，将处理的数据添加到共享数据结构中
    processed_data = [thread_id, thread_id + 1, thread_id + 2]
    
    # 获取锁，确保线程安全
    lock.acquire()
    data.append(processed_data)
    lock.release()

# 创建多个线程来处理数据
threads = []
for i in range(5):
    t = threading.Thread(target=process_data, args=(i,))
    threads.append(t)
    t.start()

# 等待所有线程完成数据处理
for t in threads:
    t.join()

# 将数据写入CSV文件
with open('data.csv', 'w', newline='') as file:
    writer = csv.writer(file)
    writer.writerow(['Column1', 'Column2', 'Column3'])  # 写入CSV文件的标题行
    writer.writerows(data)  # 写入数据行