Asyncio และวงวนอนันต์

หากคุณไม่สนใจค่าที่ส่งคืนจากข้อความจัดการ คุณสามารถสร้างงานใหม่สำหรับมันได้ ซึ่งจะทำงานในลูปเหตุการณ์ควบคู่ไปกับโปรแกรมอ่าน websocket ของคุณ นี่เป็นตัวอย่างง่ายๆ:

@asyncio.coroutine
def listener():
    while True:
        message = yield from websocket.recieve_message()
        if message:
            asyncio.ensure_future(handle(message))

ensure_future จะสร้างงานและแนบไปกับลูปเหตุการณ์เริ่มต้น เนื่องจากลูปกำลังทำงานอยู่แล้ว จึงจะได้รับการประมวลผลควบคู่ไปกับโปรแกรมอ่าน websocket ของคุณแบบขนาน ที่จริงแล้ว หากเป็นงาน I/O ที่ถูกบล็อกที่ทำงานช้า (เช่น การส่งอีเมล) คุณก็อาจมีงานจัดการ (ข้อความ) หลายสิบงานที่ทำงานพร้อมกันได้อย่างง่ายดาย พวกมันถูกสร้างขึ้นแบบไดนามิกเมื่อจำเป็น และถูกทำลายเมื่อเสร็จสิ้น (โดยมีค่าใช้จ่ายต่ำกว่าเธรดที่วางไข่มาก)

หากคุณต้องการการควบคุมเพิ่มเติมอีกเล็กน้อย คุณสามารถเขียนถึง asyncio.Queue ในเครื่องอ่านและมีกลุ่มงานที่มีขนาดคงที่ซึ่งสามารถใช้คิวได้ ซึ่งเป็นรูปแบบทั่วไปในการเขียนโปรแกรมแบบมัลติเธรดหรือหลายกระบวนการ

@asyncio.coroutine
def consumer(queue):
    while True:
        message = yield from queue.get()
        yield from handle(message)

@asyncio.coroutine
def listener(queue):
    for i in range(5):
         asyncio.ensure_future(consumer(queue))
    while True:
        message = yield from websocket.recieve_message()
        if message:
            yield from q.put(message)

q = asyncio.Queue()
loop = asyncio.get_event_loop()
loop.run_until_complete(listener(q))