Uses of Class
com.datumbox.framework.common.concurrency.ConcurrencyConfiguration
-
Packages that use ConcurrencyConfiguration Package Description com.datumbox.framework.common com.datumbox.framework.common.concurrency -
-
Uses of ConcurrencyConfiguration in com.datumbox.framework.common
Methods in com.datumbox.framework.common that return ConcurrencyConfiguration Modifier and Type Method Description ConcurrencyConfigurationConfiguration. getConcurrencyConfiguration()Getter for the Concurrency Configuration object.Methods in com.datumbox.framework.common with parameters of type ConcurrencyConfiguration Modifier and Type Method Description voidConfiguration. setConcurrencyConfiguration(ConcurrencyConfiguration concurrencyConfiguration)Setter for the Concurrency Configuration object.Constructors in com.datumbox.framework.common with parameters of type ConcurrencyConfiguration Constructor Description Configuration(StorageConfiguration storageConfiguration, ConcurrencyConfiguration concurrencyConfiguration)Public constructor, which receives the storage and concurrency configurations as arguments. -
Uses of ConcurrencyConfiguration in com.datumbox.framework.common.concurrency
Methods in com.datumbox.framework.common.concurrency with parameters of type ConcurrencyConfiguration Modifier and Type Method Description static voidThreadMethods. forkJoinExecution(Runnable runnable, ConcurrencyConfiguration concurrencyConfiguration, boolean parallelStream)Alternative to parallelStreams() which executes a runnable in a separate pool.static <T> TThreadMethods. forkJoinExecution(Callable<T> callable, ConcurrencyConfiguration concurrencyConfiguration, boolean parallelStream)Alternative to parallelStreams() which executes a callable in a separate pool.static <T> voidThreadMethods. throttledExecution(Stream<T> stream, Consumer<T> consumer, ConcurrencyConfiguration concurrencyConfiguration)Takes the items of the stream in a throttled way and provides them to the consumer.Constructors in com.datumbox.framework.common.concurrency with parameters of type ConcurrencyConfiguration Constructor Description ForkJoinStream(ConcurrencyConfiguration concurrencyConfiguration)Default constructor which receives the Concurrency Configuration object.
-