按照官方文档的描述,Task是Futrue的一个subclass,标准库中也分别提供了create_task和create_future。请问这两者有功能上的什么区别?
对于ensure_future不是很理解,官方文档对于它的描述是:
asyncio.ensure_future(coro_or_future, *, loop=None)
Schedule the execution of a coroutine object: wrap it in a future. Return a Task object.If the argument is a Future, it is returned directly.
这段描述中wrap it in a future和Return a Task应该怎么理解,以下面这段代码为例子,factorial(name, number)显然是一个coroutine object,为什么wrap它到一个future对象后又返回一个Task,拜托大神解释下?
import asyncio
@asyncio.coroutine
def factorial(name, number):
f = 1
for i in range(2, number+1):
print("Task %s: Compute factorial(%s)..." % (name, i))
yield from asyncio.sleep(1)
f *= i
print("Task %s: factorial(%s) = %s" % (name, number, f))
loop = asyncio.get_event_loop()
tasks = [
asyncio.ensure_future(factorial("A", 2)),
asyncio.ensure_future(factorial("B", 3)),
asyncio.ensure_future(factorial("C", 4))]
loop.run_until_complete(asyncio.gather(*tasks))
loop.close()
ps: 上面这段代码,如果tasks设置为下面这样,执行效果也是一样的,为什么官方文档的这个例子非要添加一个ensure_futrue,这有什么用途吗?
tasks = [
factorial("A", 2),
factorial("B", 3),
factorial("C", 4)]
第二個問題
簡單來說你可以將factorial的print看成一個return.那麼,下面的程式碼就等於在等待factorial的返回.而上面的程式碼在等待asyncio.gather的返回.而asyncio.gather會等待asyncio.ensure_future調用的任務的結果.asyncio.ensure_future是立即返回的.
在這個例子中當然看不出作用,但是,比如,你已經在進行了factorial("A", 2)的時候,你想調用factorial("B", 3)怎麼辦,等待factorial("A ", 2)的結束嗎?那實際上等於同步調用了.所以asyncio.ensure_future可以立即返回,然你不必等待factorial("A", 2)的結果即可運行factorial("A", 2)