Function consumer_process

benchmarks/benchmark_fmq.py:99–103

(consumer_id, total_msgs, result_q, consumer_event)

def consumer_process(consumer_id, total_msgs, result_q, consumer_event):
    async def run():
        await consumer_task(consumer_id, total_msgs, result_q, consumer_event)

    asyncio.run(run())


# ============================================================