Implement a producer-consumer queue using asyncio.