1 事件循环(Event Loop)应用方法

事件循环是asyncio的核心，负责调度和执行协程。它管理所有异步任务，并在适当的时候切换执行。

import asyncio

# 定义异步函数
async def main():
    print('Hello')
    await asyncio.sleep(1)  # 模拟I/O操作
    print('World')

# 获取事件循环
loop = asyncio.get_event_loop()

# 运行协程直到完成
loop.run_until_complete(main())

# 关闭事件循环
loop.close()

2 async/await应用方法

async/await是定义协程的关键字。async用于声明异步函数，await用于挂起当前协程，等待其他协程完成。

import asyncio
import time

# 模拟耗时I/O操作
async def fetch_data(task_id, delay):
    print(f"任务 {task_id} 开始，需要 {delay} 秒")
    await asyncio.sleep(delay)
    print(f"任务 {task_id} 在 {time.strftime('%X')} 完成")
    return f"任务 {task_id} 结果"

async def main():
    # 同时启动三个任务
    task1 = asyncio.create_task(fetch_data(1, 2))
    task2 = asyncio.create_task(fetch_data(2, 1))
    task3 = asyncio.create_task(fetch_data(3, 3))
    
    # 等待所有任务完成并收集结果
    results = await asyncio.gather(task1, task2, task3)
    print("所有任务完成:", results)

# Python 3.7+ 推荐用法
asyncio.run(main())

3 Future和Task应用方法

Future代表异步操作的最终结果，Task是Future的子类，用于包装协程并管理其执行状态。

import asyncio

# 使用Future的示例
async def set_future_result(future, value, delay):
    print(f"将在 {delay} 秒后设置Future结果")
    await asyncio.sleep(delay)
    future.set_result(value)

# 使用Task的示例
async def long_running_task(task_id, seconds):
    print(f"任务 {task_id} 开始，将运行 {seconds} 秒")
    for i in range(seconds):
        print(f"任务 {task_id} 进度: {i+1}/{seconds}")
        await asyncio.sleep(1)
    return f"任务 {task_id} 完成"

async def main():
    # 创建Future对象
    future = asyncio.Future()
    
    # 创建任务设置Future的结果
    asyncio.create_task(set_future_result(future, "Future完成!", 2))
    
    # 创建长时间运行的任务
    task1 = asyncio.create_task(long_running_task(1, 4))
    task2 = asyncio.create_task(long_running_task(2, 3))
    
    # 等待Future完成
    future_result = await future
    print("Future结果:", future_result)
    
    # 等待任务完成
    task_result = await asyncio.gather(task1, task2)
    print("任务结果:", task_result)

asyncio.run(main())

"对于大多数应用场景，使用async/await结合Task是最佳选择，它提供了良好的抽象和控制能力。"