asyncioを使ってクロージャを処理する方法

Question

私がやっているコントローラプロジェクトのためにいくつかの非同期メッセージングをしようとしていますが、次の関数の目的はコールバックをappjar app.registerEventコールに戻して、モータ制御UIのステータスセクション。

def motorStatusMonitor(loop: aio.AbstractEventLoop, app: aj.appjar.gui, Messenger: cmd.PyCmdMessenger.CmdMessenger)-> Callable: 
    async def getStatus(aFuture): 
     nonlocal Messenger 
     nonlocal app 
     # Ask for the current status of the motor 
     t = await Control.sendCommand(Messenger, "Status") 
     d = {t[1][0]: t[1][1], t[1][2]: t[1][3]} # parse the response 
     def statusChanger(): # need a closure to write to the app when called 
      nonlocal d # use the message from above 
      nonlocal app # use the app passed with motorStatusMonitor 
      app.openTab("Main", "Control") 
      app.openLabelFrame("Status") 
      app.setLabel("motorStatus", f"Motor A: \t\t {get('A', d, '???')}\nMotor B: \t\t {get('B', d, '???')}") # Print the status of the motors to the app 
     aFuture.set_result(statusChanger) 

    future = aio.Future() 
    aio.ensure_future(getStatus(future)) 
    loop.run_until_complete(future) 
    return future.result() 

ただし、これは機能しません。私が行ったときのように、それは永遠にハングします。

は、どのように私は実際にここに非同期の実装について行くべきか？すべてのための

完全なコードはGithubです。

Answer 1

この：

loop.run_until_complete(future) 

はそれがないことはありませんどの完了するために、将来のために待っています。

また、あなたはfuture.result()を呼び出す代わりに結果を返しますawait futureのようなものではない必要があります。