Class CompactionManager.ValidationExecutor

    • Constructor Detail

      • ValidationExecutor

        public ValidationExecutor()
    • Method Detail

      • adjustPoolSize

        public void adjustPoolSize()
      • submitIfRunning

        public com.google.common.util.concurrent.ListenableFuture<?> submitIfRunning​(java.lang.Runnable task,
                                                                                     java.lang.String name)
      • submitIfRunning

        public <T> com.google.common.util.concurrent.ListenableFuture<T> submitIfRunning​(java.util.concurrent.Callable<T> task,
                                                                                         java.lang.String name)
        Submit the task but only if the executor has not been shutdown.If the executor has been shutdown, or in case of a rejected execution exception return a cancelled future.
        Parameters:
        task - - the task to submit
        name - - the task name to use in log messages
        Returns:
        the future that will deliver the task result, or a future that has already been cancelled if the task could not be submitted.