Python中asyncio庫-線程池是什么

這篇文章將為大家詳細(xì)講解有關(guān)Python中asyncio庫-線程池是什么，小編覺得挺實(shí)用的，因此分享給大家做個參考，希望大家閱讀完這篇文章后可以有所收獲。

創(chuàng)新互聯(lián)公司電話聯(lián)系：18980820575，為您提供成都網(wǎng)站建設(shè)網(wǎng)頁設(shè)計及定制高端網(wǎng)站建設(shè)服務(wù)，創(chuàng)新互聯(lián)公司網(wǎng)頁制作領(lǐng)域十年，包括成都石牌坊等多個行業(yè)擁有豐富的網(wǎng)站運(yùn)維經(jīng)驗(yàn)，選擇創(chuàng)新互聯(lián)公司，為企業(yè)錦上添花。

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

多線程

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()
<Future at 0x107edf4e0 state=pending>
Result: A

這里面有幾個細(xì)節(jié)要注意:

協(xié)程應(yīng)該從另一個線程中調(diào)用，而非事件循環(huán)運(yùn)行所在線程，所以用asyncio.new_event_loop()新建一個事件循環(huán)

在執(zhí)行協(xié)程前要確保新創(chuàng)建的事件循環(huán)是運(yùn)行著的，所以需要用start_loop之類的方式啟動循環(huán)

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

可以通過輸出感受到future一開始是pending的，因?yàn)閰f(xié)程a里面會sleep 1秒才返回結(jié)果

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

一開始我們創(chuàng)建的新的事件循環(huán)跑在一個線程里面，由于loop.run_forever會阻塞程序關(guān)閉，所以需要結(jié)束時殺掉線程，所以用call_soon_threadsafe回調(diào)函數(shù)shutdown去停止事件循環(huán)

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

關(guān)于Python中asyncio庫-線程池是什么就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。

文章名稱：Python中asyncio庫-線程池是什么
文章路徑：http://bm7419.com/article4/jjcdoe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站排名、App設(shè)計、定制開發(fā)、虛擬主機(jī)、網(wǎng)站收錄、網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)