Interface ConcurrencyService


public interface ConcurrencyService
  • Method Details

    • getBucketedExecutor

      @Nonnull <T extends Serializable> BucketedExecutor<T> getBucketedExecutor(@Nonnull String name, @Nonnull BucketedExecutorSettings<T> settings)
      Retrieves a BucketedExecutor by name, or creates a new one if it does not already exists.
      Type Parameters:
      T - the type of settings
      Parameters:
      name - the executor name
      settings - configuration for the executor
      Returns:
      the executor, or null if it hasn't been created yet.