Python 多线程处理处理数据代码

以下是一个简单的 Python 多线程处理数据的示例代码：

import threading

def process_data(data):
    """处理数据的函数"""
    # TODO: 在这里实现数据处理逻辑
    pass

def worker():
    """工作线程函数"""
    while True:
        try:
            data = data_queue.get(block=False)
        except queue.Empty:
            # 队列已经空了，退出线程
            break
        process_data(data)
        data_queue.task_done()

# 创建数据队列
data_queue = queue.Queue()

# 往队列里面添加数据
for data in data_list:
    data_queue.put(data)

# 创建多个工作线程
num_threads = 4
threads = []
for i in range(num_threads):
    t = threading.Thread(target=worker)
    t.start()
    threads.append(t)

# 等待所有工作线程完成
for t in threads:
    t.join()

# 所有数据处理完成
print("All data processed.")

这段代码首先定义了一个 `process_data` 函数，用于实现具体的数据处理逻辑。然后创建了一个数据队列，并往队列里面添加需要处理的数据。接着创建多个工作线程，每个工作线程从队列里面获取数据并处理，直到队列为空为止。最后等待所有工作线程完成后输出处理完成的消息。在这个例子中，我们使用了 Python 自带的 `threading` 模块来实现多线程处理数据。