Django Channels AsyncConsumer未按预期异步执行问题

兄弟，我看你这问题是典型的异步协程里误用同步阻塞操作导致的！AsyncConsumer基于asyncio事件循环运行，要是你在协程里用了同步的阻塞代码（比如time.sleep(20)），整个事件循环会被卡死，没法处理其他WebSocket消息（比如你的isBusy查询），自然就没异步响应了。下面给你一步步的解决方案：

1. 替换同步阻塞操作为异步版本 #

首先，把你代码里的同步sleep换成asyncio的异步sleep，这是最常见的坑：

import asyncio
from channels.generic.websocket import AsyncJsonWebsocketConsumer

class TaskConsumer(AsyncJsonWebsocketConsumer):
    async def connect(self):
        # 每个连接维护自己的busy状态
        self.is_busy = False
        await self.accept()

    async def receive_json(self, content):
        msg_type = content.get('type')
        
        if msg_type == 'run':
            if self.is_busy:
                await self.send_json({'response': 'process is already running'})
                return
            
            self.is_busy = True
            await self.send_json({'response': 'process is running'})
            
            # 用异步sleep代替time.sleep，不会阻塞事件循环
            await asyncio.sleep(20)
            
            # 任务完成后更新状态并通知
            self.is_busy = False
            await self.send_json({'response': 'process finished'})
        
        elif msg_type == 'isBusy':
            await self.send_json({'isBusy': self.is_busy})

2. 处理CPU密集型/同步IO长时任务 #

如果你的长时进程是CPU密集型（比如大量计算）或者依赖同步IO库（比如某些不支持异步的第三方SDK），直接用asyncio协程还是会卡，这时候得把同步任务放到线程池/进程池里执行：

# 假设这是你的同步长时任务
def sync_long_task():
    # 模拟CPU密集或同步IO操作
    import time
    time.sleep(20)
    return "task completed"

async def receive_json(self, content):
    if content.get('type') == 'run':
        if self.is_busy:
            await self.send_json({'response': 'already busy'})
            return
        
        self.is_busy = True
        await self.send_json({'response': 'process starting'})
        
        # 把同步任务交给线程池执行，不阻塞事件循环
        loop = asyncio.get_event_loop()
        result = await loop.run_in_executor(None, sync_long_task)
        
        self.is_busy = False
        await self.send_json({'response': f'process finished: {result}'})

3. 额外注意事项 #

• 确保你用的是ASGI服务器（比如Daphne、Uvicorn），WSGI服务器不支持异步和WebSocket，这是基础配置问题；
• 如果busy flag是全局共享状态（比如多个连接共享一个任务状态），要用asyncio.Lock来保护，避免协程竞争：

  # 在consumer类里初始化锁
  lock = asyncio.Lock()
  
  async def receive_json(self, content):
      async with self.lock:
          # 处理busy状态的逻辑
          pass
  

这样修改后，你的isBusy消息就能正常被处理，不会被长时任务阻塞了！

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