本文详解如何修复 python socket 服务器中因线程阻塞导致主程序无法继续执行的问题，涵盖线程参数传递、客户端隔离、资源管理及主线程保活等关键实践。
在使用 threading.Thread 启动后台任务（如持续发送数据的 stream()）时，若未正确设计线程逻辑，极易出现主线程“卡死”或脚本看似无响应的现象——这并非线程本身阻塞了整个进程，而是由于未正确分离客户端连接、缺少线程参数传递、或主线程被意外阻塞所致。
以原始代码为例，问题根源有三：
- self.client 和 self.message 被所有线程共享：stream() 方法直接读取 self.client，但该属性在 run() 中被后续新连接反复覆盖，导致多客户端竞争、数据错乱甚至 AttributeError；
- 线程启动时未传入必要参数：threading.Thread(target=self.stream) 没有将当前 client 和 address 传入，使 stream() 无法操作具体连接；
- 主线程未做节奏控制：while True: print("A") 在无延迟下高频执行，易被系统调度压制，且掩盖了实际运行状态（如是否真在并行输出）。
✅ 正确做法是：每个客户端连接由独立线程处理，连接对象通过 args 显式传入，主线程保持轻量循环并添加合理延时。
以下是优化后的完整实现：
立即学习“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)
# 设置 SO_REUSEADDR 避免端口占用错误（开发调试推荐）
self.server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
self.server.bind((host, port))
self.server.listen()
print(f"Server listening on {host}:{port}")
def stream(self, client: socket.socket, address):
"""为单个客户端提供持续消息流"""
print(f"[+] New stream thread for {address}")
try:
while True:
client.send(b"hello\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:
print("[*] Waiting for connection...")
client, address = self.server.accept()
# 为每个 client 创建专属线程，并传入 client + address
thread = threading.Thread(
target=self.stream,
args=(client, address),
daemon=False # 设为 False 确保线程完成后再退出（非守护线程）
)
thread.start()
except KeyboardInterrupt:
print("\n[!] Server shutting down...")
finally:
self.server.close()# test.py
from server import Server
import threading
import time
if __name__ == "__main__":
# host='' 表示绑定所有可用接口（含局域网IP），便于树莓派连接
server = Server('', 8001)
server_thread = threading.Thread(target=server.run, name="ServerListener")
server_thread.start()
# 主线程：轻量心跳输出，验证并行性
print("[+] Main thread alive — printing dots...")
try:
while server_thread.is_alive():
print(".", end="", flush=True)
time.sleep(1)
except KeyboardInterrupt:
print("\n[!] Exiting...")
finally:
server_thread.join(timeout=2) # 安全等待线程结束? 关键改进说明：
- ✅ 参数化线程入口：stream() 接收 client 和 address，彻底解耦实例状态，支持任意数量并发客户端；
- ✅ 显式资源清理：try/except/finally 确保异常时仍关闭 socket，防止句柄泄漏；
- ✅ 主线程可控节奏：time.sleep(1) + flush=True 保证输出可见且不压垮终端；
- ✅ 健壮性增强：添加 SO_REUSEADDR、连接异常捕获、线程命名与 join() 等生产就绪实践。
? 测试建议：
使用 telnet 192.168.178.30 8001 或 Python 原生 socket 连接，观察服务端日志与客户端接收内容是否同步输出；同时确认 test.py 中的 . 持续打印，证明主线程未被阻塞。
⚠️ 注意：切勿在 stream() 中直接修改类属性（如 self.message）来通信——应使用线程安全机制（如 queue.Queue 或 threading.Event）协调数据。本例采用固定消息，故无需共享状态。
通过以上重构，你将获得一个真正异步、可扩展、易调试的 Python Socket 服务器基础框架，为后续集成键盘监听、命令路由或加密传输打下坚实基础。
