Graceful Shutdown Executor Context Manager in Python

import signal
import threading
import time
from contextlib import contextmanager


@contextmanager
def graceful_shutdown_executor(timeout=5.0):
    """Context manager that runs a task and gracefully stops it on timeout or exception."""
    stop_event = threading.Event()

    def task():
        print("Task started")
        while not stop_event.is_set():
            time.sleep(0.1)
        print("Task stopped gracefully")

    thread = threading.Thread(target=task, daemon=True)
    thread.start()

    try:
        yield stop_event
    except BaseException:
        print("Exception caught, initiating shutdown...")
        stop_event.set()
        thread.join(timeout=timeout)
        if thread.is_alive():
            print("Task still running after timeout")
        raise
    else:
        print("Context exited normally, shutting down...")
        stop_event.set()
        thread.join(timeout=timeout)
        if thread.is_alive():
            print("Task still running after timeout")


if __name__ == "__main__":
    with graceful_shutdown_executor(timeout=2.0) as stop:
        print("Inside context, doing work...")
        time.sleep(1.0)
        stop.set()  # Early stop example