关于协程转线程的一个问题

感觉你的表述并不清楚: 你没有说是如何从 coroutine send msg 到 thread 进行处理的(try contextvars); 第一个写的消息被覆盖, 是否考虑使用类似 stack 这样的数据结构 + property 防止覆盖? 如果涉及到同 /异步上下文传递, 可以考虑 `contextvars` 这个库: asyncio 在执行协程时会复制一份当前的上下文来执行, 从而避免出现覆写的问题;
希望能解决你的问题.

这个 async_event 及 sync_event 每次产生都是一对对的吗？每次 send 或者 receive 生成一个 Event （或者一对）就好了。

仔细看了一遍，题主应该是需要用个 queue 把 sync_event 串行起来吧。这样就不会先处理第二个消息了。

@linw1995 如果用 Queue 串行的话，在 coroutine 里往 threading.Queue 写数据的时候怎么异步等待呢？因为默认是同步等待的，会阻塞 send 、receive 协程。

@SaltCat 谢谢你的建议，不过这不是问题所在。

@abersheeran aio-libs 有个库叫 janus 应该能满足你的要求。

https://github.com/aio-libs/janus

@linw1995 感谢！看起来可以解决我的问题，我看看他代码怎么做的。

@abersheeran 今天发现了一个和你开发的，功能一样的轮子 https://github.com/django/asgiref

@linw1995 兄弟你是在开玩笑嘛…… asgiref 是 ASGI 标准库。里面肯定是有实现 WSGI 到 ASGI 的转换的啊！但是是个参考实现，仅仅是”可用“，速度很差劲，而且会预读 request body，大文件一来它就死了（同理，uvicorn 、starlette 里面自带的也一样）。你可以看看 a2wsgi 项目里提供的 benchmark 。

再告诉你一个秘密，如果你看看 asgiref 贡献者名单，你会发现我也在里面zero-copy send 这个拓展标准是我制定的。

@abersheeran 233 我对这方面都不关注的。这个库是在 mitmproxy 源码里发现的，还以为这个普通轮子。原来是根正苗红的官方轮子_(:_」∠)_