Python使用futures with loop_

Question

刚开始尝试异步，看起来很酷。我试图将futures与一个永远运行的异步协程一起使用，但是我得到了一个错误：

Task exception was never retrieved
future: <Task finished coro=<slow_operation() done, defined at ./asynchio-test3.py:5> exception=InvalidStateError("FINISHED: <Future finished result='This is the future!'>",)>

这是我的代码，如果我删除了与期货相关的3行代码：

^{pr2}$

Answer 1

在@false tru答案之后，这是一个完整的程序，它有3个异步协同程序，每个进程都有自己的got_result函数。我使用的是v3.4，所以我不使用新的语法。作为一个有趣的副作用，输出清楚地展示了协程的单线程特性。我希望它能作为某些人的模板：

import asyncio

@asyncio.coroutine
def task1(future):
    yield from asyncio.sleep(1)
    print ("This is operation#1")
    future.set_result('This is the result of operation #1!')
    asyncio.async(task1(new_future(got_result1)))

def got_result1(future):
    print(future.result())

@asyncio.coroutine
def task2(future):
    yield from asyncio.sleep(1)
    print ("This is operation#2")
    future.set_result('This is the result of operation #2!')
    asyncio.async(task2(new_future(got_result2)))

def got_result2(future):
    print(future.result())

@asyncio.coroutine
def task3(future):
    yield from asyncio.sleep(1)
    print ("This is operation#3")
    future.set_result('This is the result of operation #3!')
    asyncio.async(task3(new_future(got_result3)))

def got_result3(future):
    print(future.result())

def new_future(callback):
    future = asyncio.Future()
    future.add_done_callback(callback)
    return future

tasks = [task1(new_future(got_result1)),
        task2(new_future(got_result2)),
        task3(new_future(got_result3))]

loop = asyncio.get_event_loop()
for task in tasks:
    asyncio.async(task)

try:
    loop.run_forever()
finally:
    loop.close()

Answer 2

无限期地调用slow_operator，对同一未来对象多次调用^{}；这是不可能的。在

>>> import asyncio
>>> future = asyncio.Future()
>>> future.set_result('result')
>>> future.set_result('result')
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
  File "C:\Python35\lib\asyncio\futures.py", line 329, in set_result
    raise InvalidStateError('{}: {!r}'.format(self._state, self))
asyncio.futures.InvalidStateError: FINISHED: <Future finished result='result'>

为每个slow_operator调用创建新的未来。例如：

^{pr2}$

---

顺便说一句，如果您使用的是python3.5+，那么可以使用新语法（async，await）：

async def slow_operation(future):
    await asyncio.sleep(1)
    print ("This is the task!")
    future.set_result('This is the future!')
    asyncio.ensure_future(slow_operation(new_future()))