Class DefaultParallelExecutionConfiguration

    • Constructor Summary

      Constructors 
      Constructor Description
      DefaultParallelExecutionConfiguration​(int parallelism, int minimumRunnable, int maxPoolSize, int corePoolSize, int keepAliveSeconds, java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> saturate)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      int getCorePoolSize()
      Get the core thread pool size to be used.
      int getKeepAliveSeconds()
      Get the number of seconds for which inactive threads should be kept alive before terminating them and shrinking the thread pool.
      int getMaxPoolSize()
      Get the maximum thread pool size to be used.
      int getMinimumRunnable()
      Get the minimum number of runnable threads to be used.
      int getParallelism()
      Get the parallelism to be used.
      java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> getSaturatePredicate()
      Get the saturate predicate to be used for the execution's ForkJoinPool.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • parallelism

        private final int parallelism
      • minimumRunnable

        private final int minimumRunnable
      • maxPoolSize

        private final int maxPoolSize
      • corePoolSize

        private final int corePoolSize
      • keepAliveSeconds

        private final int keepAliveSeconds
      • saturate

        private final java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> saturate
    • Constructor Detail

      • DefaultParallelExecutionConfiguration

        DefaultParallelExecutionConfiguration​(int parallelism,
                                              int minimumRunnable,
                                              int maxPoolSize,
                                              int corePoolSize,
                                              int keepAliveSeconds,
                                              java.util.function.Predicate<? super java.util.concurrent.ForkJoinPool> saturate)