code: public synchronized void shutdown() {
      
      LOG.info("Shutting down all AsyncDiskService threads...");
      
      for (Map.Entry<String, ThreadPoolExecutor> e
          : executors.entrySet()) {
        e.getValue().shutdown();
      }
    }
docs: Gracefully start the shut down of all ThreadPools.