如何使asyncio池可取消？

import asyncio

async def task_logic(cancel_flag):
    try:
        while True:
            await asyncio.sleep(0)  # 允许取消点
            if cancel_flag.is_set():
                return  # 取消任务
            # 执行具体的任务逻辑
            print("Executing task...")
            await asyncio.sleep(1)  # 模拟任务执行时间
    except asyncio.CancelledError:
        return  # 捕获取消异常

async def main():
    cancel_flag = asyncio.Event()
    tasks = []

    # 创建任务池
    pool = asyncio.Queue()

    # 创建并启动多个任务
    for _ in range(5):
        task = asyncio.create_task(task_logic(cancel_flag))
        tasks.append(task)
        await pool.put(task)

    # 取消任务
    cancel_flag.set()

    # 等待所有任务完成
    await asyncio.gather(*tasks)

asyncio.run(main())