在同步線程中使用的run_in_executor就如它方法的名字所示，把協程放到了一個執行器里面，可以在一個線程池，也可以在一個進程池。另外還可以使用run_coroutine_threadsafe在其他線程執行協程(這是線程安全的)。

多線程def?start_loop(loop):

asyncio.set_event_loop(loop)

loop.run_forever()

def?shutdown(loop):

loop.stop()

async?def?b1():

new_loop?=?asyncio.new_event_loop()

t?=?Thread(target=start_loop,?args=(new_loop,))

t.start()

future?=?asyncio.run_coroutine_threadsafe(a(),?new_loop)

print(future)

print(f'Result:?{future.result(timeout=2)}')

new_loop.call_soon_threadsafe(partial(shutdown,?new_loop))

In?:?await?b1()

Result:?A

這里面有幾個細節要注意:

協程應該從另一個線程中調用，而非事件循環運行所在線程，所以用asyncio.new_event_loop()新建一個事件循環

在執行協程前要確保新創建的事件循環是運行著的，所以需要用start_loop之類的方式啟動循環

接著就可以用asyncio.run_coroutine_threadsafe執行協程a了，它返回了一個Future對象

可以通過輸出感受到future一開始是pending的，因為協程a里面會sleep 1秒才返回結果

用future.result(timeout=2)就可以獲得結果，設置timeout的值要大于a協程執行時間，要不然會拋出TimeoutError

一開始我們創建的新的事件循環跑在一個線程里面，由于loop.run_forever會阻塞程序關閉，所以需要結束時殺掉線程，所以用call_soon_threadsafe回調函數shutdown去停止事件循環

這里再說一下call_soon_threadsafe，看名字就知道它是線程安全版本的call_soon，其實就是在另外一個線程里面調度回調。BTW， 其實asyncio.run_coroutine_threadsafe底層也是用的它。

總結

以上是生活随笔為你收集整理的python asyncio future 多线程_深究Python中的asyncio库-线程池的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。