在 TCP 多线程接收数据的场景中，多个线程可能同时从网络读取数据并尝试将结果写入文件。由于文件操作本身不是线程安全的，且多个线程并发写入可能导致数据混乱或丢失，因此需要引入**队列加锁机制**来确保线程安全[^2]。 ### 使用 `queue.Queue` 实现线程安全的数据接收与写入 Python 中的 `queue.Queue` 是线程安全的数据结构，其内部已经封装了锁机制（基于 `threading.Lock`），可以确保多线程环境下对队列的 `put()` 和 `get()` 操作是原子性的。通过将接收到的数据暂存到队列中，并由单独的写入线程负责从队列取出数据写入文件，可以有效避免多个线程直接访问共享资源（如文件）带来的竞争问题[^1]。 以下是一个完整的示例，展示如何在 TCP 服务端使用多线程接收数据，并通过队列加锁机制将数据写入文件： ```python import socket import threading import queue # 全局队列用于缓存接收到的数据 data_queue = queue.Queue() # 写入文件的线程函数 def write_to_file(filename): with open(filename, 'a', encoding='utf-8') as f: while True: data = data_queue.get() if data is None: # 用于结束线程 break f.write(data + '\n') f.flush() data_queue.task_done() # 处理客户端连接的线程函数 def handle_client(conn): try: while True: data = conn.recv(1024) if not data: break data_queue.put(data.decode('utf-8')) finally: conn.close() # 启动 TCP 服务器 def start_server(): server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server_socket.bind(('0.0.0.0', 9999)) server_socket.listen(5) print("服务器已启动，等待连接...") writer_thread = threading.Thread(target=write_to_file, args=('received_data.txt',)) writer_thread.daemon = True writer_thread.start() try: while True: conn, addr = server_socket.accept() print(f"来自 {addr} 的连接") client_thread = threading.Thread(target=handle_client, args=(conn,)) client_thread.start() finally: server_socket.close() if __name__ == "__main__": start_server() ``` 上述代码中，每个客户端连接都会被分配一个独立线程进行处理，接收到的数据被放入线程安全的队列中。另一个独立线程专门负责从队列中取出数据并写入文件。这种方式通过队列的内置锁机制实现了线程间的数据同步，避免了多个线程同时操作文件所带来的冲突和异常情况[^1]。 ### 相关问题 1. 如何在 Python 中实现 TCP 客户端发送数据并通过多线程接收响应？ 2. 多线程环境下为何不能直接使用普通列表替代 `queue.Queue` 进行线程间通信？ 3. 在 Python 中，除了 `queue.Queue` 还有哪些线程安全的数据结构可用于多线程编程？ 4. 如何优化多线程 TCP 服务器的性能以应对高并发连接？