如何在独立线程运行无限循环协程？Discord Bot实践遇阻求助

我明白你的困扰——Discord Bot本身就是基于asyncio构建的，完全不需要用线程来实现并行的轮询逻辑，反而线程会打乱asyncio的调度机制，导致你遇到的那些问题。咱们直接用asyncio原生的任务调度来解决这个问题就好。

核心思路 #

Discord Bot的运行依赖于一个asyncio事件循环，我们只需要把你的轮询逻辑包装成一个异步协程，然后用asyncio.create_task()把它加入到这个事件循环中，这样Bot的消息处理、命令响应和你的轮询任务就能并行调度，互不阻塞。

完整实现示例 #

这里以discord.py为例，搭配异步HTTP库aiohttp（必须用异步库，否则同步请求会阻塞整个事件循环）：

import asyncio
import discord
from discord.ext import commands
import aiohttp

# 初始化Discord Bot
intents = discord.Intents.default()
intents.message_content = True
bot = commands.Bot(command_prefix="!", intents=intents)

# 配置参数
POLL_INTERVAL = 20  # 轮询间隔（秒）
TARGET_URL = "https://your-web-server.com/check"
TARGET_CONTENT = "特定内容"
DISCORD_CHANNEL_ID = 1234567890  # 目标频道ID

async def poll_web_server():
    """无限轮询Web服务器的异步函数"""
    # 等待Bot完全启动，避免还没准备好就发消息
    await bot.wait_until_ready()
    # 获取目标频道对象
    channel = bot.get_channel(DISCORD_CHANNEL_ID)
    if not channel:
        print("无法找到目标频道，请检查频道ID是否正确")
        return

    async with aiohttp.ClientSession() as session:
        while not bot.is_closed():
            try:
                # 异步请求Web服务器
                async with session.get(TARGET_URL) as response:
                    response_text = await response.text()
                    # 检查是否包含特定内容
                    if TARGET_CONTENT in response_text:
                        await channel.send(f"检测到目标内容！来自{TARGET_URL}")
                        # 可选：发送后可以暂停一轮，避免重复刷屏
                        await asyncio.sleep(POLL_INTERVAL)
                        continue
            except Exception as e:
                print(f"轮询出错：{str(e)}")
            
            # 等待下一轮轮询
            await asyncio.sleep(POLL_INTERVAL)

@bot.event
async def on_ready():
    print(f"已登录为 {bot.user}")
    # 启动轮询任务
    asyncio.create_task(poll_web_server())

# 运行Bot（替换成你的Bot Token）
bot.run("YOUR_BOT_TOKEN")

关键要点解析 #

1. 使用异步HTTP客户端：必须用aiohttp这类异步库，不能用requests同步库——同步请求会阻塞整个asyncio事件循环，导致Bot无法响应消息和命令。
2. asyncio.create_task()的作用：这个函数会把你的轮询协程包装成一个后台任务，加入到Bot的事件循环中，让它和Bot的其他任务（比如处理消息、事件）一起被调度执行。
3. 等待Bot启动完成：用await bot.wait_until_ready()确保Bot已经成功连接到Discord，避免在Bot未就绪时尝试发送消息导致错误。
4. 异常处理：在轮询过程中加入异常捕获，避免一次请求失败就导致整个轮询任务崩溃。

为什么你之前的方案失败？ #

• 线程跑async函数：threading.Thread(target=poll).start()这种方式不会执行协程，因为线程里没有运行asyncio事件循环，协程根本没被调度。如果去掉async，await send()又会报错，因为await只能在异步函数中使用。
• run_coroutine_threadsafe的错误用法：
  • 用asyncio.get_event_loop()时，如果你在Bot的主线程外调用，拿到的可能不是Bot正在使用的事件循环，导致任务无法被正确调度，程序冻结。
  • 用asyncio.new_event_loop()则创建了一个全新的事件循环，但这个循环没有被启动，所以协程永远不会被执行，出现“coroutine was never awaited”警告。

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