docs: public void close() {
          m_shouldContinue.set(false);
          executor.shutdownNow();
          try {
              executor.awaitTermination(5, TimeUnit.SECONDS);
          } catch (InterruptedException ignored) {}
      }