我的情况是关于通过传送带将数据流传输到消费者。我还可以做些什么？
您可以创建固定数量的任务，这些任务大致与传送带的容量相对应，然后将它们弹出队列。例如：
async def consumer(queue): while True: line = await queue.get() # connect to API, Mongo, etc. ... queue.task_done()async def producer(): N_TASKS = 10 loop = asyncio.get_event_loop() queue = asyncio.Queue(N_TASKS) tasks = [loop.create_task(consume(queue)) for _ in range(N_TASKS)] try: with open('input') as f: for line in f: await queue.put(line) await queue.join() finally: for t in tasks: t.cancel()由于与线程不同，任务是轻量级的，并且不占用操作系统资源，因此最好在创建“太多”任务时犯错。asyncio可以毫不费力地处理成千上万的任务，尽管这对于这些任务来说可能是过大的事-
几十就足够了。
