python - 等到几个绿叶中的一个完成

标签 python gevent greenlets

我有两个函数从两个不同的连接接收数据,我应该在从其中一个获得结果后关闭两个连接。

def first():
    gevent.sleep(randint(1, 100))  # i don't know how much time it will work
    return 'foo'

def second():
    gevent.sleep(randint(1, 100))  # i don't know how much time it will work
    return 'bar'

然后我生成每个函数:

lst = [gevent.spawn(first), gevent.spawn(second)]

gevent.joinall 阻塞当前的 greenlet,直到来自 lst 的两个 greenlet 都准备好了。

gevent.joinall(lst)  # wait much time
print lst[0].get(block=False)   # -> 'foo'
print lst[1].get(block=False)   # -> 'bar'

我想等到第一个或第二个 greenlet 准备就绪:

i_want_such_function(lst)  # returns after few seconds
print lst[0].get(block=False)  # -> 'foo' because this greenlet is ready
print lst[1].get(block=False)  # -> raised Timeout because this greenlet is not ready

我该怎么做?

最佳答案

您可以使用 gevent.event.Event(或 AsyncResult)和 Greenlet 的 link() 方法,如下所示:

...
ready = gevent.event.Event()
ready.clear()

def callback():
    ready.set()

lst = [gevent.spawn(first), gevent.spawn(second)]
for g in lst:
    g.link(callback)

ready.wait()
...

关于python - 等到几个绿叶中的一个完成,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/13579005/

相关文章:

python - 让 Django 变绿

python - Eventlet vs Greenlet vs gevent?

python - 使用系统托管标识从 Databricks 访问 Azure Synapse

python - 在安装期间运行自定义 setuptools build

当使用阻塞 gevent 调用时,cherrypy 会抛出异常,导致内部服务器错误

django - django <-> 应用程序服务器(node.js)之间的通信方法?

python - 如何在 Mac OS X Lion 上安装 Python 库 'gevent'

python - 修补 Python 模块时 Django 中的 Gevent 异常

python - 通过 Scrapy (Python) 将抓取的数据导出到 csv 后,我在文件中得到了像 ' 这样的字符

python - 在请求中发送多部分表单数据时是否需要使用 with 语句?