其實膨更,不去調(diào)用loop.run_until_complete就可以。
以下測試代碼:
import logging
import logging.config
import a
import time
import asyncio
async def do_something_async():
time.sleep(1)
async def test_async(i):
await asyncio.sleep(i)
a.get_logger().info("something async %d", i)
await do_something_async()
a.get_logger().info("starting coroutines")
async def main():
asyncio.ensure_future(test_async(1))
asyncio.ensure_future(test_async(3))
asyncio.ensure_future(test_async(5))
asyncio.ensure_future(test_async(3))
while True:
print('Do something different')
await asyncio.sleep(1)
asyncio.run(main())