2017-10-18 139 views
1

一致我只想運行一個簡單的測試示例,但我得到下面的錯誤。我該如何解決?python 3.6和ValueError:循環參數必須與未來

import asyncio 
import uvloop 
import concurrent.futures 
import time 
asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) 

async def do_some_work(x): 

    while True: 
     print("Waiting " + str(x)) 
     await asyncio.sleep(x) 

if __name__ == '__main__': 


    loop = asyncio.new_event_loop() 
    tasks = [asyncio.ensure_future(do_some_work(2)), 
      asyncio.ensure_future(do_some_work(5))] 
    loop.run_until_complete(asyncio.gather(*tasks)) 

Traceback (most recent call last): 
    File "/Users/worker_why.py", line 23, in <module> 
    loop.run_until_complete(asyncio.gather(*tasks)) 
    File "uvloop/loop.pyx", line 1181, in uvloop.loop.Loop.run_until_complete (uvloop/loop.c:25184) 
    File "/Library/Frameworks/Python.framework/Versions/3.6/lib/python3.6/asyncio/tasks.py", line 508, in ensure_future 
    raise ValueError('loop argument must agree with Future') 
ValueError: loop argument must agree with Future 
+1

您是否嘗試過通過新創建的循環, 'ensure_future'? 'asyncio.ensure_future(...,loop = loop)' – vaultah

回答

1
loop = asyncio.new_event_loop() 

如果你創建新的事件循環,不想到處傳遞,你也應該讓這個循環電流方面:

loop = asyncio.new_event_loop() 
asyncio.set_event_loop(loop) 
相關問題