在python中，我如何运行并发生成器循环，当其中一个发生故障时会暂停或终止？

import asyncio

# 定义一个生成器函数
async def generator_func():
    while True:
        # 生成数据
        data = generate_data()
        # 发送数据给消费者
        yield data

# 定义一个消费者函数
async def consumer_func():
    while True:
        try:
            # 从生成器中获取数据
            data = next(generator)
            # 处理数据
            process_data(data)
        except StopIteration:
            # 生成器已经结束，退出循环
            break
        except Exception as e:
            # 发生故障，暂停或终止
            handle_failure(e)
            break

# 创建一个事件循环
loop = asyncio.get_event_loop()

# 创建一个生成器对象
generator = generator_func()

# 创建一个任务列表
tasks = [consumer_func() for _ in range(10)]

# 运行任务列表
loop.run_until_complete(asyncio.gather(*tasks))

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