self._lock = threading.Lock()
self._observer = Observer()
self._observer.schedule(self, path=dir_path, recursive=True)
def start(self):
self._lock = threading.Lock()
self._observer = Observer()
self._observer.schedule(self, path=dir_path, recursive=True)
def start(self):