首頁  >  文章  >  後端開發  >  非同步事件與條件:Python 交通號誌的秘密生活

非同步事件與條件:Python 交通號誌的秘密生活

Susan Sarandon
Susan Sarandon原創
2024-10-07 16:12:01635瀏覽

Asyncio Events and Conditions: The Secret Life of Python

有沒有想過你的 Python 協程如何能夠在不造成交通擁堵的情況下很好地協同工作?讓我們深入了解非同步事件和條件的異想天開的世界 - 阻止您的非同步程式碼變成馬戲團的無名英雄(除非您願意)。

活動:大家都在等待的綠燈
將 asyncio.Event 視為代碼中的紅綠燈。協程排隊並耐心(或不那麼耐心)等待燈變綠,然後再縮小。

想像一下你和一群人(協程)在人行道上。行人號誌燈是紅色的(事件未設定),所以每個人都在等待。當它變成綠色的那一刻(event.set()),整個團隊一致前進。沒有人願意成為那個因為闖紅燈而躲避汽車的人。


import asyncio

async def pedestrian(event):
    print("Pedestrian is waiting for the signal.")
    await event.wait()
    print("Pedestrian crosses the street.")

async def traffic_light(event):
    print("Traffic light is red.")
    await asyncio.sleep(2)
    event.set()
    print("Traffic light turns green.")

async def main():
    event = asyncio.Event()
    await asyncio.gather(pedestrian(event), traffic_light(event))

asyncio.run(main())


輸出:


Pedestrian is waiting for the signal.
Traffic light is red.
Traffic light turns green.
Pedestrian crosses the street.


條件:俱樂部 VIP 通行證
asyncio.Condition 就像是高級俱樂部的保鑣。你不僅需要俱樂部開放(有條件),還需要滿足一定的條件(await condition.wait())。

嘗試進入時尚夜店的照片。俱樂部(條件)容量有限,只有當其他人離開(滿足條件)時,保鑣才允許您進入。您可能會在外面等待,練習您最好的舞蹈動作(或尷尬地查看手機),直到獲得認可。


import asyncio

async def clubber(condition, name):
    async with condition:
        print(f"{name} wants to enter the club.")
        await condition.wait()
        print(f"{name} enters the club.")

async def bouncer(condition):
    await asyncio.sleep(2)
    async with condition:
        print("Bouncer signals someone can enter.")
        condition.notify()

async def main():
    condition = asyncio.Condition()
    await asyncio.gather(
        clubber(condition, "Alice"),
        clubber(condition, "Bob"),
        bouncer(condition)
    )

asyncio.run(main())


輸出:


Alice wants to enter the club.
Bob wants to enter the club.
Bouncer signals someone can enter.
Alice enters the club.


在此範例中,只有一名俱樂部成員可以進入俱樂部,因為保鑣只向一個人發出訊號 (condition.notify())。另一名俱樂部成員仍在無限期地等待。如果你想讓每個人都進來(聚會時間!),你可以使用condition.notify_all()。


import asyncio

async def clubber(condition, name):
    async with condition:
        print(f"{name} wants to enter the club.")
        await condition.wait()
        print(f"{name} enters the club.")

async def bouncer(condition):
    await asyncio.sleep(2)
    async with condition:
        print("Bouncer signals everyone can enter.")
        condition.notify_all()

async def main():
    condition = asyncio.Condition()
    await asyncio.gather(
        clubber(condition, "Alice"),
        clubber(condition, "Bob"),
        bouncer(condition)
    )

asyncio.run(main())


輸出:


Alice wants to enter the club.
Bob wants to enter the club.
Bouncer signals everyone can enter.
Alice enters the club.
Bob enters the club.


聚會結束
現在,您應該對 asyncio eventsconditions 的工作原理有了更清晰的了解。他們是幕後協調員,確保一切順利進行。

所以,下次當你的非同步代碼不再像高速公路上的撞車事故時,你就知道該感謝誰了!

以上是非同步事件與條件:Python 交通號誌的秘密生活的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn