gevent 不公平调度：一个greenlet 中的密集数据读取循环导致其他人挨饿？

如何解决gevent 不公平调度：一个greenlet 中的密集数据读取循环导致其他人挨饿？

我想就 gevent 应用程序的这种典型情况提供一些建议，它具有 一个greenlet从服务器接收大量数据：似乎一个greenlet可以阻止所有数据 其他人从执行。当然 gevent 是合作的，但我认为切换会 发生在 I/O 操作上，所以在某些时候我会想象另一个 greenlet 会是 即使有大量数据要接收，也可以调度和执行...

在 gevent 中是否有一些调度？ 有没有办法实现更公平的调度？

为了演示目的，让我们想象一个这样的服务器（不需要 gevent）：

import socket

s = socket.socket()
s.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1)
s.bind(("",9998))

while True:
    s.listen()
    client,_ = s.accept()
    while True:
        client.send(2048*b"!")

这是客户端测试程序（使用 gevent）：

import gevent
from gevent import monkey ; monkey.patch_all()
import socket

def reading():
    s = socket.socket()
    s.connect(("localhost",9998))
    print("entering reading loop")
    while True:
        data = s.recv(1024)
        if not data:
            break
        # gevent.sleep(0) - putting sleep here 'solves' the issue

def something_else():
    while True:
        print("before sleep")
        gevent.sleep(0.5)
        print("after sleep")

gevent.spawn(something_else)
gevent.sleep(1) # ensure greenlet is started
gevent.spawn(reading)
gevent.wait()

reading 函数使用来自服务器的数据。 运行此测试时，"entering reading loop" 后没有输出；两个greenlets都在运行， 但是执行 something_else 的 greenlet 永远不会再被调度 就像阅读一样。

在阅读循环中添加 gevent.sleep(0) 解决了这个问题，因为它“强制”合作。但是，这是唯一的希望吗？ 我觉得这很奇怪，因为我认为 gevent 应该在 I/O 期间切换：即使读取循环很密集，我也希望在 recv 时刻执行另一个 greenlet。

这是 gevent 中的错误吗？

是否存在其他日程安排选项？