[已解决]python协程问题

是肥宅SRP啊

我是Windows系统，输入的代码如下，想问问该怎么解决这个问题呀

1. import asyncio
   
2. 
   
3. async def fun1():
   
4.     print('I am INsider1')
   
5.     await asyncio.sleep(1)
   
6.     print('1finished')
   
7. 
   
8. async def fun2():
   
9.     print("I am INsider2")
   
10.     await asyncio.sleep(2)
    
11.     print("2finished")
    
12. 
    
13. async def fun3():
    
14.     print("I am INsider3")
    
15.     await asyncio.sleep(3)
    
16.     print("3finished")
    
17. 
    
18. if __name__ == '__main__':
    
19.     f1 = fun1()
    
20.     f2 = fun2()
    
21.     f3 = fun3()
    
22. 
    
23.     fs = [f1,f2,f3]
    
24.     event_loop = asyncio.get_event_loop()
    
25.     event_loop.run_until_complete(asyncio.wait(fs))

复制代码

报错如下：

1.     raise TypeError("Passing coroutines is forbidden, use tasks explicitly.")
   
2. TypeError: Passing coroutines is forbidden, use tasks explicitly.
   
3. sys:1: RuntimeWarning: coroutine 'fun1' was never awaited
   
4. sys:1: RuntimeWarning: coroutine 'fun2' was never awaited
   
5. sys:1: RuntimeWarning: coroutine 'fun3' was never awaited

复制代码

最佳答案

月排行榜 / 总排行榜

isdkz

2023-4-24 21:02:52

从您的错误提示来看，问题出在您将协程函数直接传递给`asyncio.wait()`。解决这个问题的方法是使用`asyncio.create_task()`将协程函数包装为任务对象，然后传递这些任务对象给`asyncio.wait()`。请修改您的代码如下：

1. import asyncio
   
2. 
   
3. async def fun1():
   
4.     print('I am INsider1')
   
5.     await asyncio.sleep(1)
   
6.     print('1finished')
   
7. 
   
8. async def fun2():
   
9.     print("I am INsider2")
   
10.     await asyncio.sleep(2)
    
11.     print("2finished")
    
12. 
    
13. async def fun3():
    
14.     print("I am INsider3")
    
15.     await asyncio.sleep(3)
    
16.     print("3finished")
    
17. 
    
18. if __name__ == '__main__':
    
19.     f1 = fun1()
    
20.     f2 = fun2()
    
21.     f3 = fun3()
    
22. 
    
23.     fs = [f1,f2,f3]
    
24.    
    
25.     event_loop = asyncio.get_event_loop()
    
26.    
    
27.     # 将协程对象包装为任务对象
    
28.     tasks = [event_loop.create_task(f) for f in fs]
    
29. 
    
30.     # 将任务对象传递给 asyncio.wait
    
31.     event_loop.run_until_complete(asyncio.wait(tasks))
    

复制代码

现在，您的代码应该可以正常运行并输出预期结果。另外，从Python 3.7开始，可以使用`asyncio.run()`简化事件循环的创建和关闭操作，不过这需要将您的代码封装在一个异步函数中。如果您的Python版本 >= 3.7，可以考虑将代码改成如下：

1. import asyncio
   
2. 
   
3. async def fun1():
   
4.     print('I am INsider1')
   
5.     await asyncio.sleep(1)
   
6.     print('1finished')
   
7. 
   
8. async def fun2():
   
9.     print("I am INsider2")
   
10.     await asyncio.sleep(2)
    
11.     print("2finished")
    
12. 
    
13. async def fun3():
    
14.     print("I am INsider3")
    
15.     await asyncio.sleep(3)
    
16.     print("3finished")
    
17. 
    
18. async def main():
    
19.     f1 = fun1()
    
20.     f2 = fun2()
    
21.     f3 = fun3()
    
22. 
    
23.     fs = [f1,f2,f3]
    
24.    
    
25.     tasks = [asyncio.create_task(f) for f in fs]
    
26.     await asyncio.wait(tasks)
    
27. 
    
28. if __name__ == '__main__':
    
29.     asyncio.run(main())
    

复制代码

这样，代码会更简洁。

跳转到最佳答案楼层

isdkz

从您的错误提示来看，问题出在您将协程函数直接传递给`asyncio.wait()`。解决这个问题的方法是使用`asyncio.create_task()`将协程函数包装为任务对象，然后传递这些任务对象给`asyncio.wait()`。请修改您的代码如下：

1. import asyncio
   
2. 
   
3. async def fun1():
   
4.     print('I am INsider1')
   
5.     await asyncio.sleep(1)
   
6.     print('1finished')
   
7. 
   
8. async def fun2():
   
9.     print("I am INsider2")
   
10.     await asyncio.sleep(2)
    
11.     print("2finished")
    
12. 
    
13. async def fun3():
    
14.     print("I am INsider3")
    
15.     await asyncio.sleep(3)
    
16.     print("3finished")
    
17. 
    
18. if __name__ == '__main__':
    
19.     f1 = fun1()
    
20.     f2 = fun2()
    
21.     f3 = fun3()
    
22. 
    
23.     fs = [f1,f2,f3]
    
24.    
    
25.     event_loop = asyncio.get_event_loop()
    
26.    
    
27.     # 将协程对象包装为任务对象
    
28.     tasks = [event_loop.create_task(f) for f in fs]
    
29. 
    
30.     # 将任务对象传递给 asyncio.wait
    
31.     event_loop.run_until_complete(asyncio.wait(tasks))
    

复制代码

现在，您的代码应该可以正常运行并输出预期结果。另外，从Python 3.7开始，可以使用`asyncio.run()`简化事件循环的创建和关闭操作，不过这需要将您的代码封装在一个异步函数中。如果您的Python版本 >= 3.7，可以考虑将代码改成如下：

1. import asyncio
   
2. 
   
3. async def fun1():
   
4.     print('I am INsider1')
   
5.     await asyncio.sleep(1)
   
6.     print('1finished')
   
7. 
   
8. async def fun2():
   
9.     print("I am INsider2")
   
10.     await asyncio.sleep(2)
    
11.     print("2finished")
    
12. 
    
13. async def fun3():
    
14.     print("I am INsider3")
    
15.     await asyncio.sleep(3)
    
16.     print("3finished")
    
17. 
    
18. async def main():
    
19.     f1 = fun1()
    
20.     f2 = fun2()
    
21.     f3 = fun3()
    
22. 
    
23.     fs = [f1,f2,f3]
    
24.    
    
25.     tasks = [asyncio.create_task(f) for f in fs]
    
26.     await asyncio.wait(tasks)
    
27. 
    
28. if __name__ == '__main__':
    
29.     asyncio.run(main())
    

复制代码

这样，代码会更简洁。