Python 3.6 异步函数以最简单的方式循环

Posted 2023-03-30

【中文标题】Python 3.6 异步函数以最简单的方式循环

【英文标题】：Python 3.6 async function over loop in the simplest way possible

【发布时间】：2019-09-10 19:11:01

【问题描述】：

我需要做的就是编写一个简单的异步函数来返回一些东西。类似于

async def diss(lis):
  x = []
  for i in lis:
    x.append(i + 1) #the operation is arbitrary, but the input and output of a list is the desired result
  return x

lis = [1, 2, 3, 4]
res = await diss(lis)

但是，这给了我在 await diss(lis) 处的语法错误

我在网上找到的都是一些教程，其中在异步函数中打印了一些东西，但是当我尝试返回一些东西时，我总是收到一个协程或未来对象。

我的目标本质上是让循环异步运行，以提高性能，然后返回一些东西

【问题讨论】：

您是否尝试在事件循环之外等待协程？您需要获取或创建一个事件循环并在其中运行协程。最简单的方法是使用asyncio.run

根据[***.com/questions/52796630/…我发现python 3.6 asyncio不支持运行

【参考方案1】：

给你：

import asyncio


async def diss(lis):
  x = []
  for i in lis:
    x.append(i + 1)
  return x


async def main():
  lis = [1, 2, 3, 4]
  res = await diss(lis)
  return res


loop = asyncio.get_event_loop()
res = loop.run_until_complete(main())
print(res)

---

确保您了解why and when to use asyncio in the first place。例如，没有必要使上面的代码异步。

通常，当您有多个可以与 asyncio.gather() 并行化的 I/O 操作时，您可能只需要 asyncio。

【讨论】：

谢谢。我想我对异步操作太陌生了，不知道。这非常有帮助。我需要执行的实际操作涉及调用在服务器上进行计算的外部 api。我想我需要使用进程池执行程序来做我需要做的事情。我只需要想出一种方法来循环将每个操作放在自己的进程中。再次感谢您

这是否意味着我们应该使这段代码同步而不是异步？

@mic 在这种情况下：是的。没有法律规定这段代码应该是同步的，但让它异步是没有意义的。你只是不会从中得到任何好处。通常，只有在处理某些 I/O 或作为并行化某些计算的一种方式（当您可以并行化它们时）时，您才想编写异步代码。请从链接中查看the answer，那里的示例很少。

【参考方案2】：

async def diss(lis):
  x = []
  for i in lis:
    x.append(i + 1)
  return x

async def dat():
  res = await diss(lis)
  return res

loop = asyncio.get_event_loop()

done, _ = loop.run_until_complete(asyncio.wait([dat()]))

for fut in done:
    a = fut.result()

是我为解决 a 是预期结果的问题所做的。这有什么问题吗？

【讨论】：

它可以写得更短：result = loop.run_until_complete(dat())。当并行等待几件事情时，你只需要 asyncio.wait()。