วิธี Handle Python Exception ใน Threads

ใช้ Queue ส่ง exception จาก worker thread ไป main thread

ตัวอย่าง

import sys
import threading
import time
import Queue

def thread(args1, stop_event, queue_obj):
    print("start thread")
    stop_event.wait(12)
    if not stop_event.is_set():
        try:
            raise Exception("boom!")
        except Exception:
            queue_obj.put(sys.exc_info())

try:
    queue_obj = Queue.Queue()
    t_stop = threading.Event()
    t = threading.Thread(target=thread, args=(1, t_stop, queue_obj))
    t.start()
    time.sleep(15)
    print("stop thread!")
    t_stop.set()
    
    try:
        exc = queue_obj.get(block=False)
    except Queue.Empty:
        pass
    else:
        exc_type, exc_obj, exc_trace = exc
        print(exc_obj)
except Exception as e:
    print("It took too long")

ผลลัพธ์

start thread
stop thread!
boom!