code: public void shutdownBlocking() throws InterruptedException
      {
          executor.shutdown();
          executor.awaitTermination();
          allocator.shutdown();
          allocator.awaitTermination();
      }
docs: Shuts down the threads used by the commit log, blocking until completion.