def stop(self):
    self.__is_shutdown.set()
    self.__is_stopped.wait()
    self.join(THREAD_TIMEOUT_MAX)
def stop(self):
    self.__is_shutdown.set()
    self.__is_stopped.wait()
    self.join(THREAD_TIMEOUT_MAX)