- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
假设我们有一个虚拟函数:
async def foo(arg):
result = await some_remote_call(arg)
return result.upper()
两者有什么区别:
import asyncio
coros = []
for i in range(5):
coros.append(foo(i))
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(coros))
还有:
import asyncio
futures = []
for i in range(5):
futures.append(asyncio.ensure_future(foo(i)))
loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait(futures))
注意:示例返回结果,但这不是问题的重点。当返回值很重要时,使用 gather()
而不是 wait()
。
无论返回值如何,我都在寻找关于 ensure_future()
的清晰度。 wait(coros)
和 wait(futures)
都运行协程,那么协程何时以及为什么应该包含在 ensure_future
中?
基本上,使用 Python 3.5 的 async
运行一堆非阻塞操作的正确方法 (tm) 是什么?
为了获得额外的信用,如果我想批量调用怎么办?例如,我需要调用 some_remote_call(...)
1000 次,但我不想用 1000 个同时连接来破坏 Web 服务器/数据库/等。这对于线程或进程池是可行的,但是有没有办法使用 asyncio
来做到这一点?
2020 年更新(Python 3.7+):不要使用这些代码段。而是使用:
import asyncio
async def do_something_async():
tasks = []
for i in range(5):
tasks.append(asyncio.create_task(foo(i)))
await asyncio.gather(*tasks)
def do_something():
asyncio.run(do_something_async)
还可以考虑使用 Trio ,asyncio 的强大的第 3 方替代方案。
最佳答案
协程是一个生成器函数,它既可以产生值,也可以接受来自外部的值。使用协程的好处是我们可以暂停函数的执行并在以后恢复它。在网络操作的情况下,在我们等待响应时暂停函数的执行是有意义的。我们可以利用这段时间来运行一些其他的功能。
future 就像 Javascript 中的 Promise
对象。它就像一个占位符,用于表示将来会实现的值。在上面提到的情况下,在等待网络 I/O 时,一个函数可以给我们一个容器,这是一个 promise ,当操作完成时它将用该值填充容器。我们保留 future 对象,当它完成时,我们可以调用它的方法来检索实际结果。
直接回答:如果您不需要结果,则不需要 ensure_future
。如果您需要结果或检索发生的异常,它们很好。
额外积分:我会选择 run_in_executor
并传递一个 Executor
实例来控制最大工作人员的数量。
在第一个示例中,您使用的是协程。 wait
函数需要一堆协程并将它们组合在一起。所以 wait()
在所有协程都用尽时完成(完成/完成返回所有值)。
loop = get_event_loop() #
loop.run_until_complete(wait(coros))
run_until_complete
方法将确保循环在执行完成之前一直处于事件状态。请注意在这种情况下您如何没有获得异步执行的结果。
在第二个例子中,你使用 ensure_future
函数来包装一个协程并返回一个 Task
对象,它是一种 Future
.当您调用 ensure_future
时,协程计划在主事件循环中执行。返回的 future/task 对象还没有值,但随着时间的推移,当网络操作完成时,future 对象将保存操作的结果。
from asyncio import ensure_future
futures = []
for i in range(5):
futures.append(ensure_future(foo(i)))
loop = get_event_loop()
loop.run_until_complete(wait(futures))
所以在这个例子中,我们在做同样的事情,除了我们使用 future 而不是仅仅使用协程。
我们来看一个如何使用 asyncio/coroutines/futures 的例子:
import asyncio
async def slow_operation():
await asyncio.sleep(1)
return 'Future is done!'
def got_result(future):
print(future.result())
# We have result, so let's stop
loop.stop()
loop = asyncio.get_event_loop()
task = loop.create_task(slow_operation())
task.add_done_callback(got_result)
# We run forever
loop.run_forever()
在这里,我们在 loop
对象上使用了 create_task
方法。 ensure_future
将在主事件循环中安排任务。这种方法使我们能够在我们选择的循环上调度协程。
我们还看到了在任务对象上使用 add_done_callback
方法添加回调的概念。
当协程返回值、引发异常或被取消时,Task
是 done
。有一些方法可以检查这些事件。
我写了一些关于这些主题的博客文章,可能会有所帮助:
当然,您可以在官方手册中找到更多详细信息:https://docs.python.org/3/library/asyncio.html
关于python - Python 3.5 中协程和 future /任务之间的区别?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34753401/
我正在通过这个示例https://www.rusoto.org/futures.html学习Rust和Rusoto 而且我发现许多代码已经过时了。所以我改变了这样的代码: use rusoto_cor
这是一个理论问题。我有一个服务可以调用来完成工作,但该服务可能无法完成所有工作,因此我需要调用第二个服务来完成它。 我想知道是否有办法在没有 Await.result 的情况下做类似的事情map 函数
这个问题是关于如何阅读 Rust 文档并提高我对 Rust 的理解,从而了解如何解决这个特定的编译器错误。 我读过 tokio docs并试验了许多 examples .在编写自己的代码时,我经常遇到
我有一个使用分页的 HTTP api,我想将它包装到一个通用的 Rust 流中,以便所有端点都可以使用相同的接口(interface),这样我就可以使用 Stream 附带的特征函数特征。 我收到了这
我正在查看 AKKA 的 Java Futures API,我看到了很多处理同一类型的多个 future 的方法,但我没有看到任何处理不同类型的 future 的方法。我猜我让事情变得更加复杂了。 无
环境:Akka 2.1,scala 版本 2.10.M6,JDK 1.7,u5 现在是我的问题: 我有: future1 = Futures.future(new Callable>(){...});
我有一些代码可以将请求提交给另一个线程,该线程可能会也可能不会将该请求提交给另一个线程。这会产生 Future> 的返回类型.是否有一些非令人发指的方法可以立即将其变成 Future等待整个 futu
如果我有以下代码: Future a = new Future(() { print('a'); return 1; }); Future b = new Future.error('Error!')
我一直试图简化我在 Scala 中做 future 的方式。我有一次收到了 Future[Option[Future[Option[Boolean]]但我在下面进一步简化了它。有没有更好的方法来简化这
Scala 中从 Future[Option[Future[Int]]] 转换的最干净的方法是什么?至 Future[Option[Int]] ?甚至有可能吗? 最佳答案 有两个嵌套Future s
使用下面的示例,future2 如何在 future1 完成后使用 future1 的结果(不阻塞 future3 从被提交)? from concurrent.futures import Proc
这两个类代表了并发编程的优秀抽象,因此它们不支持相同的 API 有点令人不安。 具体根据docs : asyncio.Future is almost compatible with concurre
我正在尝试使用 wasm_bindgen 实现 API 类使用异步调用。 #![allow(non_snake_case)] use std::future::Future; use serde::{
这个问题在这里已经有了答案: Futures / Success race (3 个回答) 去年关闭。 所有的 future 最终可能会成功(有些可能会失败),但我们希望第一个成功。并希望将这一结果表
我在练习asyncio在编写多线程代码多年之后。 注意到一些我觉得很奇怪的东西。都在 asyncio在 concurrent有一个Future目的。 from asyncio import Futur
如何将Future[Option[Future[Option[X]]]]转换为Future[Option[X]]? 如果它是 TraversableOnce 而不是 Option 我会使用 Futur
我正在尝试同时发送 HTTP 请求。为此,我使用 concurrent.futures 这是简单的代码: import requests from concurrent import futures
我们在 vertx 中使用 Futures 的例子如下: Future fetchVehicle = getUserBookedVehicle(routingContext, client);
下面的函数,取自 here : fn connection_for( &self, pool_key: PoolKey, ) -> impl Future>, ClientError>
我正在围绕Java库编写一个小的Scala包装器。 Java库有一个对象QueryExecutor,它公开了2种方法: execute(query):结果 asyncExecute(query):Li
我是一名优秀的程序员,十分优秀!