Class IgniteStripedThreadPoolExecutor

  • All Implemented Interfaces:
    Executor, ExecutorService, org.apache.ignite.internal.processors.pool.MetricsAwareExecutorService

    public class IgniteStripedThreadPoolExecutor
    extends Object
    implements ExecutorService, org.apache.ignite.internal.processors.pool.MetricsAwareExecutorService
    An ExecutorService that executes submitted tasks using pooled grid threads.
    • Constructor Detail

      • IgniteStripedThreadPoolExecutor

        public IgniteStripedThreadPoolExecutor​(int concurrentLvl,
                                               String igniteInstanceName,
                                               String threadNamePrefix,
                                               Thread.UncaughtExceptionHandler eHnd,
                                               boolean allowCoreThreadTimeOut,
                                               long keepAliveTime)
        Create striped thread pool.
        Parameters:
        concurrentLvl - Concurrency level.
        igniteInstanceName - Node name.
        threadNamePrefix - Thread name prefix.
        allowCoreThreadTimeOut - Sets the policy governing whether core threads may time out and terminate if no tasks arrive within the keep-alive time.
        keepAliveTime - When the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating.
        eHnd - Uncaught exception handler.