python中Task封装协程的知识点总结

1. Task封装协程

在Python异步编程中，Task是一个非常重要的概念。Task是用来封装协程的，可以通过Task来管理协程。在使用协程时，经常需要创建多个协程，然后将它们注册到事件循环中，这个过程比较繁琐，而Task就是用来解决这个问题。通过Task，我们可以将协程封装成一个任务，然后将任务添加到事件循环中执行。

1.1 如何创建Task

在Python中，可以使用asyncio的create_task()函数来创建Task。

import asyncio
async def func():
    await asyncio.sleep(1)
    print("task done")
async def main():
    task = asyncio.create_task(func())
    await task
asyncio.run(main())

在上面的代码中，我们创建了一个协程函数func()，然后使用create_task()函数创建了一个Task，将协程函数作为参数传递给它。最后，我们在主函数中await了Task，等待Task完成。

1.2 如何取消Task

在某些情况下，我们可能需要取消Task，比如任务执行时间过长，或者任务执行过程中出现错误等。对于这种情况，Python提供了cancel()方法，可以取消一个正在运行的Task。

import asyncio
async def func():
    await asyncio.sleep(10)
    print("task done")
async def main():
    loop = asyncio.get_running_loop()
    task = loop.create_task(func())
    await asyncio.sleep(1)
    task.cancel()
    print("task cancelled")
asyncio.run(main())

在上面的代码中，我们创建了一个协程函数func()，然后使用create_task()函数创建了一个Task，并让它睡眠10秒钟。接着，在主函数中我们等待1秒钟后，使用cancel()方法取消Task，最后输出任务取消的信息。

1.3 如何获取Task的状态

Task有三种状态：PENDING、RUNNING、FINISHED。我们可以使用status()方法来获取Task的状态。

import asyncio
async def func():
    await asyncio.sleep(1)
    print("task done")
async def main():
    task = asyncio.create_task(func())
    print(task.status())
    await task
    print(task.status())
asyncio.run(main())

在上面的代码中，我们创建了一个协程函数func()，然后使用create_task()函数创建了一个Task，并使用status()方法输出了Task的状态。此时，Task的状态应该是PENDING。接着，我们await Task，等待任务完成，然后再次使用status()方法输出Task的状态，此时Task的状态应该是FINISHED。

2. 将Task封装成协程

虽然Task非常方便，但是有时候我们需要将Task封装成协程，以便于在其他协程中调用。在Python中，可以使用asyncio的wait()函数将多个Task封装成一个协程。

import asyncio
async def func1():
    await asyncio.sleep(1)
    print("func1 done")
async def func2():
    await asyncio.sleep(2)
    print("func2 done")
async def main():
    tasks = [asyncio.create_task(func1()), asyncio.create_task(func2())]
    await asyncio.wait(tasks)
asyncio.run(main())

在上面的代码中，我们创建了两个协程函数func1()和func2()，然后使用create_task()函数创建了两个Task，将它们存放在一个列表中。接着，我们使用wait()函数将这个列表中的Task封装成一个协程，然后在主函数中await这个协程，等待任务完成。

3. Task的返回值

在异步编程中，有时候我们需要获取协程的返回值。在Python中，Task的返回值就是协程的返回值。

import asyncio
async def func():
    await asyncio.sleep(1)
    return "task done"
async def main():
    task = asyncio.create_task(func())
    result = await task
    print(result)
asyncio.run(main())

在上面的代码中，我们创建了一个协程函数func()，然后使用create_task()函数创建了一个Task，并将Task的返回值存放在变量result中。最后，我们将这个变量输出。

4. 总结

Task是Python异步编程中非常重要的概念，通过Task我们可以封装协程，方便地管理协程。Task的状态有三种：PENDING、RUNNING、FINISHED，可以使用status()方法获取Task的状态。Task可以通过cancel()方法来取消任务，通过get_result()方法来获取任务的结果。在需要时，我们可以将多个Task封装成一个协程，以便于在其他协程中调用。