12

考虑以下程序（在 CPython 3.4.0b1 上运行）：

import math
import asyncio
from asyncio import coroutine

@coroutine
def fast_sqrt(x):
   future = asyncio.Future()
   if x >= 0:
      future.set_result(math.sqrt(x))
   else:
      future.set_exception(Exception("negative number"))
   return future


def slow_sqrt(x):
   yield from asyncio.sleep(1)
   future = asyncio.Future()
   if x >= 0:
      future.set_result(math.sqrt(x))
   else:
      future.set_exception(Exception("negative number"))
   return future


@coroutine
def run_test():
   for x in [2, -2]:
      for f in [fast_sqrt, slow_sqrt]:
         try:
            future = yield from f(x)
            print("\n{} {}".format(future, type(future)))
            res = future.result()
            print("{} result: {}".format(f, res))
         except Exception as e:
            print("{} exception: {}".format(f, e))


loop = asyncio.get_event_loop()
loop.run_until_complete(run_test())

我有 2 个（相关）问题：

  1. 即使使用了装饰器fast_sqrt，Python 似乎也完全优化了创建的 Future fast_sqrt，并返回了一个纯float文本。然后run_test()在yield from

  2. 为什么我需要进行评估future.result()以run_test检索引发异常的值？文档说“yield from <future>暂停协程直到未来完成，然后返回未来的结果，或者引发异常”。为什么我需要手动检索未来的结果？

这是我得到的：

oberstet@COREI7 ~/scm/tavendo/infrequent/scratchbox/python/asyncio (master)
$ python3 -V
Python 3.4.0b1
oberstet@COREI7 ~/scm/tavendo/infrequent/scratchbox/python/asyncio (master)
$ python3 test3.py

1.4142135623730951 <class 'float'>
<function fast_sqrt at 0x00B889C0> exception: 'float' object has no attribute 'result'

Future<result=1.4142135623730951> <class 'asyncio.futures.Future'>
<function slow_sqrt at 0x02AC8810> result: 1.4142135623730951
<function fast_sqrt at 0x00B889C0> exception: negative number

Future<exception=Exception('negative number',)> <class 'asyncio.futures.Future'>
<function slow_sqrt at 0x02AC8810> exception: negative number
oberstet@COREI7 ~/scm/tavendo/infrequent/scratchbox/python/asyncio (master)

好的，我找到了“问题”。yield from asyncio.sleepin将slow_sqrt自动使其成为协程。等待需要以不同的方式完成：

def slow_sqrt(x):
   loop = asyncio.get_event_loop()
   future = asyncio.Future()
   def doit():
      if x >= 0:
         future.set_result(math.sqrt(x))
      else:
         future.set_exception(Exception("negative number"))
   loop.call_later(1, doit)
   return future

所有 4 个变体都在这里。

4

1 回答 1

6

关于#1：Python 没有这样的事情。请注意，fast_sqrt您编写的函数（即在任何装饰器之前）不是生成器函数、协程函数、任务或任何您想要调用的函数。return它是一个普通函数，同步运行并在语句之后返回你写的内容。根据 的存​​在@coroutine，会发生非常不同的事情。两者都导致相同的错误只是运气不好。

  1. 没有装饰器，fast_sqrt(x)它就像普通函数一样运行并返回一个浮点数的未来（不管上下文）。那个未来被 消耗掉future = yield from ...，留下future一个浮点数（它没有result方法）。

  2. 使用装饰器，调用f(x)通过由@coroutine. 这个包装器函数使用构造函数为您调用fast_sqrt并解包生成的未来。yield from <future>因此，这个包装函数本身就是一个协程。因此，再次future = yield from ...等待该协程并留下future一个浮点数。

关于＃2，yield from <future> 确实有效（如上所述，您在使用 undecorated 时正在使用它fast_sqrt），您也可以编写：

future = yield from coro_returning_a_future(x)
res = yield from future

（模数它不能fast_sqrt像写的那样工作，并且不会让你获得额外的异步性，因为未来在它从返回时已经完成coro_returning_a_future。）

您的核心问题似乎是您混淆了协程和期货。您的两个 sqrt 实现都尝试成为导致期货的异步任务。根据我有限的经验，这不是人们通常编写异步代码的方式。它允许您将未来的构建和未来所代表的计算拉到两个独立的异步任务中。但是你不这样做（你返回一个已经完成的未来）。大多数时候，这不是一个有用的概念：如果你必须异步进行一些计算，你要么将其编写为协程（可以暂停） ，要么将其推送到另一个线程并使用yield from <future>. 不是都。

要使平方根计算异步，只需编写一个常规协程来进行计算和return结果（coroutine装饰器将fast_sqrt变成一个异步运行的任务，可以等待）。

@coroutine
def fast_sqrt(x):
   if x >= 0:
      return math.sqrt(x)
   else:
      raise Exception("negative number")

@coroutine # for documentation, not strictly necessary
def slow_sqrt(x):
   yield from asyncio.sleep(1)
   if x >= 0:
      return math.sqrt(x)
   else:
      raise Exception("negative number")

...
res = yield from f(x)
assert isinstance(res, float)
于 2013-12-22T12:36:27.800 回答