本文详解如何修复 python socket 服务器中因线程阻塞导致主线程无法继续执行的问题，重点说明 `thread.start()` 后主线程挂起的常见误区，并提供可稳定运行的多线程服务端模板。
在使用 threading.Thread 创建后台任务（如长循环的客户端通信）时，一个常见误解是：调用 thread.start() 就能“自动释放”主线程控制权。实际上，问题往往不出在 start() 本身，而在于目标函数是否被正确设计为非阻塞、可并发执行的逻辑，以及主线程是否因未做任何耗时/等待操作而意外退出或被覆盖。
观察原始代码，核心问题有三处：
stream() 方法无参数却依赖实例变量 self.client 和 self.message
由于多个客户端连接会共享同一个 Server 实例，self.client 在新连接到来时被覆盖，导致前一个线程向已失效的 socket 发送数据，极易触发 BrokenPipeError 或静默卡死；同时 self.message == "" 导致发送空字节流，部分 TCP 栈可能不立即刷新缓冲区，造成“假死”现象。run() 中未对 stream() 线程设置守护属性（daemon=True），但主线程缺乏保活机制
虽然 thread.start() 正确启动了子线程，但 test.py 中的 while True: print("A") 本应持续输出，却未生效——根本原因是：该循环运行极快，大量 print 输出被系统缓冲或终端渲染延迟掩盖；更关键的是，若 server.run() 所在线程因异常终止（如 socket 错误未捕获），而主线程又未做任何显式等待，整个进程可能因无活跃非守护线程而退出。缺少基础错误处理与资源管理
原始代码未捕获 socket.error、ConnectionResetError 等常见网络异常，也未关闭 socket，易导致文件描述符泄漏和端口占用。
✅ 正确做法如下：
- 为每个客户端分配独立线程，并传入专属 socket 对象：避免共享状态冲突；
- 在 stream() 中添加心跳/延时（如 time.sleep(1)）：防止高频发送压垮连接，也便于观察线程行为；
- 主线程需主动维持运行（如 time.sleep()）并捕获中断信号：确保其不因 CPU 占满或意外退出而终止；
- 推荐将服务线程设为守护线程（daemon=True）：使主程序退出时子线程自动结束，避免僵尸线程。
以下是优化后的完整可运行示例：
立即学习“Python免费学习笔记（深入）”；
# server.py
import socket
import threading
import time
class Server:
def __init__(self, host: str, port: int):
self.host = host
self.port = port
self.server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
self.server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) # 允许端口重用
self.server.bind((host, port))
self.server.listen(5) # 设置最大连接队列长度
print(f"Server listening on {host}:{port}")
def stream(self, client: socket.socket, address):
"""为单个客户端提供持续服务"""
print(f"[+] New connection from {address}")
try:
while True:
client.send(b"HELLO FROM SERVER\n")
time.sleep(1)
except (ConnectionResetError, BrokenPipeError, OSError) as e:
print(f"[-] Client {address} disconnected: {e}")
finally:
client.close()
def run(self):
"""主监听循环 —— 每接受一个连接即启动一个新线程"""
try:
while True:
client, address = self.server.accept()
# 为每个客户端创建独立线程，传入专属 socket
thread = threading.Thread(
target=self.stream,
args=(client, address),
daemon=True # 设为守护线程，主程序退出时自动终止
)
thread.start()
except KeyboardInterrupt:
print("\n[!] Server shutting down...")
finally:
self.server.close()# test.py
from server import Server
import time
if __name__ == "__main__":
# 绑定到所有接口（''）以支持局域网连接
server = Server('', 8001)
# 启动服务线程
server_thread = threading.Thread(target=server.run, daemon=False)
server_thread.start()
# 主线程持续运行，输出提示并响应 Ctrl+C
print("Server started. Press Ctrl+C to stop.")
try:
while server_thread.is_alive():
print(".", end="", flush=True)
time.sleep(1)
except KeyboardInterrupt:
print("\n[!] Exiting...")? 关键注意事项：
- ✅ 使用 daemon=True 可避免子线程阻止主程序退出，但需确保关键清理逻辑（如 server.close()）放在 run() 的 finally 块中；
- ✅ self.server.setsockopt(... SO_REUSEADDR ...) 防止重启时报 “Address already in use”；
- ✅ client.send() 前无需 encode() 若直接发送 bytes 字面量（如 b"..."），语义更清晰；
- ❌ 避免在 stream() 中修改共享实例变量（如 self.message），应通过参数传递或使用线程局部存储（threading.local）隔离状态。
运行后，你将看到 . 持续打印，同时终端显示连接日志；用 telnet 192.168.178.30 8001 或 Python socket 客户端连接即可收到连续的 HELLO FROM SERVER 消息——主线程与服务线程真正并行无阻。
