Django Channels发消息遇RuntimeError：解释器关闭后无法调度新future

1. 解释器关闭后线程仍持续运行 #

你的后台线程是无限循环逻辑，当gunicorn/daphne的worker进程因资源耗尽、超时或其他触发条件退出时，Python解释器会进入关闭流程，但该后台线程未收到退出信号，仍在尝试创建新的asyncio事件循环并调度future。此时解释器已无法处理新的异步任务，因此抛出RuntimeError: cannot schedule new futures after interpreter shutdown错误。

2. 重复发送旧消息的根源 #

当解释器进入关闭状态后，主进程的业务逻辑（包括message变量的更新）已停止，但后台线程的循环仍在执行。此时读取的message会停留在出错前的最后一个有效值，加上异常捕获仅打印错误未终止循环，导致线程持续重复发送这条旧消息。

1. 使用持久化asyncio事件循环 #

避免在每次循环中创建、销毁事件循环，改为在线程内初始化一次循环，用asyncio.sleep替代time.sleep，既避免阻塞线程，也让事件循环能响应退出信号。

2. 添加优雅退出机制 #

设置线程级停止标志，监听主进程的退出信号（如SIGTERM、SIGINT），触发后终止循环，避免线程在解释器关闭后继续运行。

3. 保证消息读取的线程安全 #

通过锁或队列机制，确保后台线程能获取到最新的message值，同时避免读取到失效的旧值。

import asyncio
import threading
import traceback
import json
import signal
from channels.layers import get_channel_layer
from queue import Queue

channel_layer = get_channel_layer()
# 线程停止标志
stop_event = threading.Event()
# 用队列传递最新消息，保证线程安全
message_queue = Queue(maxsize=1)

def update_message(new_msg):
    """外部更新消息的接口，确保最新消息被放入队列"""
    if message_queue.full():
        message_queue.get()
    message_queue.put(new_msg)

async def send_data():
    try:
        msg = message_queue.get() if not message_queue.empty() else {}
        await channel_layer.group_send(
            'Live_Message_Layer',
            {
                'type': 'send_live_message',
                'value': {'live_message': json.dumps(msg)}
            }
        )
    except RuntimeError as e:
        if "cannot schedule new futures after interpreter shutdown" in str(e):
            print("Interpreter shutting down, stopping worker thread")
            stop_event.set()
        else:
            print("Error while sending message ...\n", traceback.format_exc())
    except Exception as e:
        print("Error while sending message ...\n", traceback.format_exc())

async def worker_loop():
    while not stop_event.is_set():
        await send_data()
        await asyncio.sleep(0.5)

class MyWorker(threading.Thread):
    def __init__(self):
        super().__init__()
        # 设置为守护线程，配合stop_event实现双重退出保障
        self.daemon = True

    def run(self):
        print('Worker is running .....')
        loop = asyncio.new_event_loop()
        asyncio.set_event_loop(loop)
        
        # 注册信号处理，捕获主进程退出信号
        def handle_signal(signum, frame):
            stop_event.set()
        signal.signal(signal.SIGTERM, handle_signal)
        signal.signal(signal.SIGINT, handle_signal)
        
        try:
            loop.run_until_complete(worker_loop())
        finally:
            loop.close()

# 启动线程
MyWorker().start()

• gunicorn的worker进程可能因配置的--timeout或内存限制自动重启，需确保后台线程能被正确终止，避免僵尸线程。
• 若使用多worker模式，每个worker都会启动独立的后台线程，需根据业务场景调整消息传递逻辑（比如用Redis共享消息，而非进程内队列）。

内容的提问来源于stack exchange，提问作者Django Developer