下面是一个示例代码,展示了如何使用asyncio.create_task
来立即执行协程:
import asyncio
async def my_coroutine():
print('Coroutine is running')
async def main():
print('Creating task...')
task = asyncio.create_task(my_coroutine())
print('Task created')
await asyncio.sleep(1)
print('Sleep done')
asyncio.run(main())
在上面的代码中,my_coroutine
是一个简单的协程函数,它只是打印一条消息。main
函数是我们的主函数,负责创建和执行协程。
在main
函数中,我们首先打印了一条消息,然后使用asyncio.create_task
来创建一个任务,该任务会立即执行my_coroutine
协程。然后,我们打印了另一条消息,然后使用asyncio.sleep
来模拟一些其他的异步操作。最后,我们打印了最后一条消息。
当我们运行上述代码时,输出将会是:
Creating task...
Task created
Coroutine is running
Sleep done
可以看到,asyncio.create_task
确实立即执行了协程。