Function run

benchmarks/benchmark_fmq.py:55–56

()

def producer_process(proc_id, msg_count, payload_size, shm_threshold, result_q):
    async def run():
        await producer_task(proc_id, msg_count, payload_size, shm_threshold, result_q)

    asyncio.run(run())