def METHOD_NAME(self):
    """Start closure event loop if not started"""
    if self._closure_event_loop is None:
        def event_loop():
            # Run loop until closure event is set and closure queue is empty
            while True:
                try:
                    closure = self._closure_queue.get(block=True, timeout=3)
                    closure()
                    self._closure_queue.task_done()
                except EmptyQueue:
                    with self._closure_lock:
                        if self._closure_queue.empty():
                            self._closure_event_loop_finished.set()
                            return
                except Exception as e:
                    self._closure_exception.put(e)
                    return
        self._closure_event_loop = threading.Thread(target=event_loop)
        self._closure_event_loop.start()