None 使用 asyncio 阻止“while True”

Question

使用下面的代码，我尝试使用 asyncio 启动 2 个无限循环：

async def do_job_1():

    while True :

        print('do_job_1')

        await asyncio.sleep(5)

async def do_job_2():

    while True :

        print('do_job_2')

        await asyncio.sleep(5)

if __name__ == '__main__':

    asyncio.run(do_job_1())

    asyncio.run(do_job_2())

do_job_1块do_job_2，因为do_job_2从不打印 do_job_1。我犯了什么错误？

最终我试图转换kafka消费者代码：

from confluent_kafka import Consumer, KafkaError

settings = {

    'bootstrap.servers': 'localhost:9092',

    'group.id': 'mygroup',

    'client.id': 'client-1',

    'enable.auto.commit': True,

    'session.timeout.ms': 6000,

    'default.topic.config': {'auto.offset.reset': 'smallest'}

}

c = Consumer(settings)

c.subscribe(['mytopic'])

try:

    while True:

        msg = c.poll(0.1)

        if msg is None:

            continue

        elif not msg.error():

            print('Received message: {0}'.format(msg.value()))

        elif msg.error().code() == KafkaError._PARTITION_EOF:

            print('End of partition reached {0}/{1}'

                  .format(msg.topic(), msg.partition()))

        else:

            print('Error occured: {0}'.format(msg.error().str()))

except KeyboardInterrupt:

    pass

finally:

    c.close()

摘自https://www.confluence.io/blog/introduction-to-apache-kafka-for-python-programmers是并发的，这样我就可以并行处理 Kafka 消息。

Answer 1

来自help(asyncio.run)：它应该用作 asyncio 程序的主要入口点，并且最好只调用一次。但您可以使用asyncio.gather加入任务：import asyncioasync def do_job_1():    while True :        print('do_job_1')        await asyncio.sleep(5)async def do_job_2():    while True :        print('do_job_2')        await asyncio.sleep(5)async def main():    await asyncio.gather(do_job_1(), do_job_2())if __name__ == '__main__':    asyncio.run(main())