如何使用asyncio在异步生成器上进行“轮询”或“选择”

import asyncio

async def async_generator_1():
    for i in range(5):
        await asyncio.sleep(1)
        yield f'Generator 1 - Item {i}'

async def async_generator_2():
    for i in range(5):
        await asyncio.sleep(1)
        yield f'Generator 2 - Item {i}'

async def poll_generators():
    gen1 = async_generator_1()
    gen2 = async_generator_2()

    async def get_next_item(gen):
        try:
            return await gen.__anext__()
        except StopAsyncIteration:
            return None

    while True:
        item1 = await get_next_item(gen1)
        item2 = await get_next_item(gen2)

        if item1 is None and item2 is None:
            break

        if item1 is not None:
            print(item1)

        if item2 is not None:
            print(item2)

        await asyncio.sleep(0)  # 让出控制权，允许其他任务运行

async def main():
    await poll_generators()

# 运行事件循环
asyncio.run(main())