我有一个asyncio.Queue生产者和使用者作为两个无限循环运行。生产者定期将作业添加到队列中,使用者等待作业可用,然后处理作业,然后等待下一个作业。然而,出于某种原因,我的消费者并没有接到电话。我认为这是因为生产者的任务从来不屈服于消费者?import concurrent.futures de
我最近一直在和异步打交道,当我开始对它的工作方式有直觉的时候,有些事情我还没能做。我不确定这是因为我搞错了建筑,还是我想要做的事情没有道理。简而言之,我希望能够迭代生成的asyncio.coroutine。例如,我希望能够做这样的事情:def countdown(n): yield from asyncio.sleep(1)