建站
咨詢(xún)
售后
建站咨詢(xún)
新聞中心
在同步線(xiàn)程中使用的run_in_executor就如它方法的名字所示，把協(xié)程放到了一個(gè)執(zhí)行器里面，可以在一個(gè)線(xiàn)程池，也可以在一個(gè)進(jìn)程池。另外還可以使用run_coroutine_threadsafe在其他線(xiàn)程執(zhí)行協(xié)程（這是線(xiàn)程安全的）。
創(chuàng)新互聯(lián)公司主要從事成都網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)、企業(yè)做網(wǎng)站、公司建網(wǎng)站等業(yè)務(wù)。立足成都服務(wù)裕安,十多年網(wǎng)站建設(shè)經(jīng)驗(yàn),價(jià)格優(yōu)惠、服務(wù)專(zhuān)業(yè),歡迎來(lái)電咨詢(xún)建站服務(wù):028-86922220
多線(xiàn)程
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 這里面有幾個(gè)細(xì)節(jié)要注意:
協(xié)程應(yīng)該從另一個(gè)線(xiàn)程中調(diào)用，而非事件循環(huán)運(yùn)行所在線(xiàn)程，所以用asyncio.new_event_loop()新建一個(gè)事件循環(huán)
在執(zhí)行協(xié)程前要確保新創(chuàng)建的事件循環(huán)是運(yùn)行著的，所以需要用start_loop之類(lèi)的方式啟動(dòng)循環(huán)
接著就可以用asyncio.run_coroutine_threadsafe執(zhí)行協(xié)程a了，它返回了一個(gè)Future對(duì)象
可以通過(guò)輸出感受到future一開(kāi)始是pending的，因?yàn)閰f(xié)程a里面會(huì)sleep 1秒才返回結(jié)果
用future.result(timeout=2)就可以獲得結(jié)果，設(shè)置timeout的值要大于a協(xié)程執(zhí)行時(shí)間，要不然會(huì)拋出TimeoutError
一開(kāi)始我們創(chuàng)建的新的事件循環(huán)跑在一個(gè)線(xiàn)程里面，由于loop.run_forever會(huì)阻塞程序關(guān)閉，所以需要結(jié)束時(shí)殺掉線(xiàn)程，所以用call_soon_threadsafe回調(diào)函數(shù)shutdown去停止事件循環(huán)
這里再說(shuō)一下call_soon_threadsafe，看名字就知道它是線(xiàn)程安全版本的call_soon，其實(shí)就是在另外一個(gè)線(xiàn)程里面調(diào)度回調(diào)。BTW， 其實(shí)asyncio.run_coroutine_threadsafe底層也是用的它。
本文名稱(chēng)：創(chuàng)新互聯(lián)Python教程：深究Python中的asyncio庫(kù)-線(xiàn)程池
網(wǎng)頁(yè)URL：http://fisionsoft.com.cn/article/dpdsgcp.html
