在按键传递取消令牌时停止异步任务中的foreach

import asyncio

# 标志变量，用于表示是否需要取消任务
cancel_flag = False

async def async_task():
    global cancel_flag
    
    # 异步任务中的foreach循环
    async for item in async_generator():
        # 检查标志变量的值
        if cancel_flag:
            break
        
        # 执行异步任务的操作
        await process_item(item)

async def process_item(item):
    # 执行异步任务的操作
    print(item)

async def async_generator():
    # 异步生成器，用于生成数据
    for i in range(10):
        yield i
        await asyncio.sleep(1)

# 按键触发取消任务的函数
def cancel_task():
    global cancel_flag
    cancel_flag = True

# 启动异步任务
asyncio.ensure_future(async_task())

# 模拟按键触发取消任务
cancel_task()

# 运行事件循环
loop = asyncio.get_event_loop()
loop.run_forever()