code: public static ServiceAdapter<ExecutorService> forExecutorService() {
  		return new SimpleServiceAdapter<ExecutorService>(false, true) {
  			@Override
  			protected void start(ExecutorService instance) {
  			}
  
  			@Override
  			protected void stop(ExecutorService instance) throws Exception {
  				List<Runnable> runnables = instance.shutdownNow();
  				if (!runnables.isEmpty()) {
  					logger.warn("Cancelled tasks: " + runnables);
  				}
  				if (!instance.isTerminated()) {
  					logger.warn("Awaiting termination of " + instance + " ...");
  					instance.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);
  				}
  			}
  		};
  	}
docs: Returns factory which transforms ExecutorService to ConcurrentService. On starting it doing nothing, on stopping it shuts down ExecutorService.