Python 异步编程 asyncio简介及基本用法

import asyncio
# 定义一个异步函数
async def my_coroutine():
    print("开始任务")
    # 模拟一个耗时操作
    await asyncio.sleep(1)  # 等待1秒
    print("任务完成")
# 创建事件循环
loop = asyncio.get_event_loop()
# 运行异步函数直到完成
loop.run_until_complete(my_coroutine())
# 关闭事件循环
loop.close()

import asyncio
# 定义一个异步函数
async def my_coroutine1():
    print("开始任务1")
    # 模拟一个耗时操作
    await asyncio.sleep(1)  # 等待1秒
    print("任务完成1")
async def my_coroutine2():
    print("开始任务2")
    # 模拟一个耗时操作
    await asyncio.sleep(1)  # 等待1秒
    print("任务完成2")
async def main():
    results =  await asyncio.gather(my_coroutine1(), my_coroutine2())
    print(results)
if __name__ == '__main__':
    asyncio.run(main())

async def function_name(parameters):
    # 协程体

await expression

import asyncio
async def task1():
    print("Task 1 started")
    await asyncio.sleep(1)
    print("Task 1 completed")
async def task2():
    print("Task 2 started")
    await asyncio.sleep(2)
    print("Task 2 completed")
async def main():
    # 创建任务但不等待它们
    task_1 = asyncio.create_task(task1())
    task_2 = asyncio.create_task(task2())
    # 执行其他代码...
    # 等待任务完成
    await task_1
    await task_2
# 运行主函数
asyncio.run(main())

import asyncio
async def task1():
    print("Task 1 started")
    await asyncio.sleep(1)
    print("Task 1 completed")
    return "Result from Task 1"
async def task2():
    print("Task 2 started")
    await asyncio.sleep(2)
    print("Task 2 completed")
    return "Result from Task 2"
async def main():
    # 使用 gather 同时运行多个任务
    results = await asyncio.gather(task1(), task2())
    print(results)
# 运行主函数
asyncio.run(main())

import asyncio
async def task1():
    print("Task 1 started")
    await asyncio.sleep(1)
    print("Task 1 completed")
async def task2():
    print("Task 2 started")
    await asyncio.sleep(2)
    print("Task 2 completed")
async def main():
    # 创建任务列表
    tasks = [task1(), task2()]
    # 等待所有任务完成
    done, pending = await asyncio.wait(tasks, return_when=asyncio.ALL_COMPLETED)
    for future in done:
        print(future.result())
# 运行主函数
asyncio.run(main())

import asyncio
async def task1():
    print("Task 1 started")
    await asyncio.sleep(1)
    print("Task 1 completed")
    return "Result from Task 1"
async def task2():
    print("Task 2 started")
    await asyncio.sleep(2)
    print("Task 2 completed")
    return "Result from Task 2"
async def main():
    # 创建任务列表
    tasks = [task1(), task2()]
    # 按完成顺序处理结果
    for future in asyncio.as_completed(tasks):
        result = await future
        print(result)
# 运行主函数
asyncio.run(main())