def shutdown_listener(cls): if cls._queue: cls._queue.put(None) try: cls._queue.get(timeout=3) except TimeoutError: pass