Python中的異步與同步：深度解析與實(shí)踐

在Python編程世界里，異步和同步的概念是理解程序執(zhí)行流程和性能優(yōu)化的關(guān)鍵。這篇文章將帶你深入了解它們的差異，以及阻塞和非阻塞的特性，同時(shí)通過(guò)實(shí)際代碼示例來(lái)加深理解。

異步與同步的定義

異步

異步意味著多任務(wù)處理，任務(wù)之間的執(zhí)行沒(méi)有嚴(yán)格的先后順序，甚至可以同時(shí)運(yùn)行。這就好比你一邊聽(tīng)音樂(lè)，一邊瀏覽網(wǎng)頁(yè)，聽(tīng)音樂(lè)和瀏覽網(wǎng)頁(yè)這兩個(gè)任務(wù)之間互不干擾，多條任務(wù)的執(zhí)行路徑同時(shí)存在，程序有多個(gè)“主線”并行處理任務(wù)。

同步

同步同樣是處理多任務(wù)，但任務(wù)之間有嚴(yán)格的先后順序。只有前一個(gè)任務(wù)執(zhí)行完成，下一個(gè)任務(wù)才能開(kāi)始。這類似于你排隊(duì)買東西，必須一個(gè)人買完，下一個(gè)人才能接著買，整個(gè)過(guò)程只有一條“主線”。

阻塞與非阻塞的概念

阻塞

從調(diào)用者的角度來(lái)看，如果在調(diào)用某個(gè)操作時(shí)，程序被卡住，無(wú)法繼續(xù)向下執(zhí)行，必須等待該操作完成，這種情況就是阻塞。比如你打電話叫外賣，在等待外賣送達(dá)的這段時(shí)間里，你什么其他事都做不了，只能干等著，這就是“阻塞”狀態(tài)。

非阻塞

當(dāng)調(diào)用某個(gè)操作時(shí)，程序不會(huì)被卡住，能夠繼續(xù)向下執(zhí)行，無(wú)需等待該操作完成，這就是非阻塞。還是以叫外賣為例，你下單后可以繼續(xù)做自己的事情，不用一直等著外賣，這就是“非阻塞”狀態(tài)。

同步阻塞與異步非阻塞示例

下面通過(guò)Python代碼來(lái)具體展示異步和同步的工作方式。這里我們使用multiprocessing模塊中的Pool來(lái)創(chuàng)建進(jìn)程池，實(shí)現(xiàn)多任務(wù)處理。

from multiprocessing import Pool
import time
import os
def water():
    """燒水"""
    print(f"子進(jìn)程 pid={os.getpid()}")
    for i in range(5):
        print("正在燒水中")
        time.sleep(0.5)
    return "水燒開(kāi)了"
def handle_water(message):
    """接收燒開(kāi)水的信息"""
    print(f"進(jìn)程pid={os.getpid()} 收到了異步任務(wù)的結(jié)束信息: {message}")
pool = Pool(3)
print(f"主進(jìn)程 pid={os.getpid()}")
for i in range(3):
    print("打游戲")
    time.sleep(0.5)
# 回調(diào)
pool.apply_async(water, callback=handle_water)  # 異步添加任務(wù)
for i in range(20):
    print("打游戲")
    time.sleep(0.5)
pool.close()
pool.join()

在這段代碼中：

• 首先創(chuàng)建了一個(gè)進(jìn)程池Pool，最大進(jìn)程數(shù)為3。
• 主進(jìn)程先執(zhí)行一段“打游戲”的操作，循環(huán)3次，每次間隔0.5秒。
• 然后使用pool.apply_async方法異步地添加water任務(wù)到進(jìn)程池，并設(shè)置了回調(diào)函數(shù)handle_water。water任務(wù)模擬燒水過(guò)程，會(huì)打印當(dāng)前子進(jìn)程ID并每隔0.5秒輸出“正在燒水中”，完成后返回“水燒開(kāi)了”。handle_water函數(shù)用于接收water任務(wù)完成后的信息并打印。
• 接著主進(jìn)程繼續(xù)執(zhí)行“打游戲”操作，循環(huán)20次，每次間隔0.5秒。這期間，water任務(wù)在后臺(tái)異步執(zhí)行。
• 最后，調(diào)用pool.close()關(guān)閉進(jìn)程池，不再接受新任務(wù)，pool.join()讓主進(jìn)程等待所有子進(jìn)程完成任務(wù)后再結(jié)束。

通過(guò)這個(gè)示例，可以清晰地看到異步任務(wù)在后臺(tái)執(zhí)行，不會(huì)阻塞主進(jìn)程的其他操作，體現(xiàn)了異步非阻塞的特性。如果將pool.apply_async換成pool.apply，那么就是同步阻塞的效果，water任務(wù)執(zhí)行時(shí)會(huì)阻塞主進(jìn)程，直到任務(wù)完成才會(huì)繼續(xù)執(zhí)行后續(xù)代碼。

理解異步、同步、阻塞和非阻塞的概念，能幫助開(kāi)發(fā)者根據(jù)實(shí)際需求優(yōu)化程序性能，合理利用系統(tǒng)資源，讓程序運(yùn)行得更加高效和靈活。無(wú)論是處理I/O密集型任務(wù)，還是CPU密集型任務(wù)，選擇合適的執(zhí)行方式都是關(guān)鍵。

到此這篇關(guān)于Python 中的異步與同步：解析與實(shí)踐的文章就介紹到這了,更多相關(guān)Python 異步與同步內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論