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

import asyncio
 
async def func():
print(1)
await asyncio.sleep(2)
print(2)
return "返回值"
 
 
async def main():
print("main开始")
 
# 创建协程，将协程封装到Task对象中并添加到事件循环的任务列表中，等待事件循环去执行（默认是就绪状态）。
# 在调用
task_list = [
asyncio.create_task(func(), name="n1"),
asyncio.create_task(func(), name="n2")
]
 
print("main结束")
 
# 当执行某协程遇到IO操作时，会自动化切换执行其他任务。
# 此处的await是等待所有协程执行完毕，并将所有协程的返回值保存到done
# 如果设置了timeout值，则意味着此处最多等待的秒，完成的协程返回值写入到done中，未完成则写到pending中。
done, pending = await asyncio.wait(task_list, timeout=None)
print(done, pending)
 
 
asyncio.run(main())

import asyncio
import arrow

def current_time():
 '''
 获取当前时间
 :return:
 '''
 cur_time = arrow.now().to('Asia/Shanghai').format('YYYY-MM-DD HH:mm:ss')
 return cur_time

async def func(sleep_time):
 func_name_suffix = sleep_time  # 使用 sleep_time（函数 I/O 等待时长）作为函数名后缀，以区分任务对象
 print(f"[{current_time()}] 执行异步函数 {func.__name__}-{func_name_suffix}")
 await asyncio.sleep(sleep_time)
 print(f"[{current_time()}] 函数 {func.__name__}-{func_name_suffix} 执行完毕")
 return f"【[{current_time()}] 得到函数 {func.__name__}-{func_name_suffix} 执行结果】"

async def run():
 task_list = []
 for i in range(5):
  task = asyncio.create_task(async_func(i))
  task_list.append(task)
 done, pending = await asyncio.wait(task_list, timeout=None)
 for done_task in done:
  print((f"[{current_time()}] 得到执行结果 {done_task.result()}"))
def main():
 loop = asyncio.get_event_loop()
 loop.run_until_complete(run())

if __name__ == '__main__':
 main()