异步Flask集成Async Redis遇RuntimeError：不同事件循环绑定问题求助

你遇到的RuntimeError: got Future <Future pending> attached to a different loop，根源是Flask默认多线程模式下，每个工作线程会创建独立的事件循环，而你的Redis连接池绑定在了初始线程的事件循环上。当其他线程处理请求时，Redis操作生成的Future属于另一个循环，导致循环不匹配的冲突。

需要明确的是：事件循环本身不是线程安全的，强制多个线程共享同一个事件循环会引发线程安全问题，不建议这么做。以下是两种更合理的解决方案：

方案1：改用异步WSGI服务器（推荐） #

Flask 2.0+支持异步视图，但默认的Werkzeug开发服务器在多线程模式下对异步的处理不够友好。改用hypercorn或uvicorn这类原生支持异步的服务器，它们会统一管理事件循环，避免多线程间的循环冲突：

1. 安装依赖：

pip install hypercorn

2. 修改代码适配异步服务器：

import redis.asyncio as redis
from flask import Flask

app = Flask('Flask')
# 初始化Redis实例，由异步服务器统一管理循环
r = redis.Redis(host='0.0.0.0', port=6379, db=0)

@app.route('/get', methods=['GET'])
async def get_value():
    value = await r.get('key')
    return value

if __name__ == '__main__':
    from hypercorn.asyncio import serve
    from hypercorn.config import Config
    config = Config()
    config.bind = ["0.0.0.0:5000"]
    # 可根据需求调整进程数，每个进程有独立的安全循环
    config.workers = 2
    import asyncio
    asyncio.run(serve(app, config))

此方案中，服务器会为每个工作进程维护独立的事件循环，既保证了异步操作的安全，也能利用多进程提升并发能力。

方案2：为每个线程创建独立的Redis连接池 #

如果必须使用Flask默认的多线程开发服务器，可以用threading.local()为每个线程存储独立的Redis实例，确保每个线程的Redis操作绑定到当前线程的事件循环：

import threading
import redis.asyncio as redis
from flask import Flask

app = Flask('Flask')
# 线程本地存储，每个线程拥有专属的Redis实例
thread_local = threading.local()

def get_redis():
    if not hasattr(thread_local, 'redis'):
        thread_local.redis = redis.Redis(host='0.0.0.0', port=6379, db=0)
    return thread_local.redis

@app.route('/get', methods=['GET'])
async def get_value():
    r = get_redis()
    value = await r.get('key')
    return value

if __name__ == '__main__':
    app.run(threaded=True)

这样每个请求所在的线程会初始化自己的Redis连接，避免跨线程的循环不匹配问题。

当设置threaded=False时，Flask用单线程处理每个进程内的请求；开启processes=2后，每个进程有独立的事件循环和Redis连接池，进程间相互隔离，因此每个请求都能在对应进程的循环中正常执行，不会出现循环冲突。

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