org.apache.ignite.internal.processors.security.thread

Class SecurityAwareStripedThreadPoolExecutor

java.lang.Object

org.apache.ignite.thread.IgniteStripedThreadPoolExecutor

org.apache.ignite.internal.processors.security.thread.SecurityAwareStripedThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService, MetricsAwareExecutorService

public class SecurityAwareStripedThreadPoolExecutor
extends IgniteStripedThreadPoolExecutor

Extends IgniteStripedThreadPoolExecutor with the ability to execute tasks in security context that was actual when task was added to executor's queue.

Constructor Summary

Constructors

Constructor and Description
SecurityAwareStripedThreadPoolExecutor(IgniteSecurity security, int concurrentLvl, String igniteInstanceName, String threadNamePrefix, Thread.UncaughtExceptionHandler eHnd, boolean allowCoreThreadTimeOut, long keepAliveTime)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable task, int idx) Executes the given command at some time in the future.

Methods inherited from class org.apache.ignite.thread.IgniteStripedThreadPoolExecutor

awaitTermination, execute, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, registerMetrics, shutdown, shutdownNow, submit, submit, submit, threadId, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

SecurityAwareStripedThreadPoolExecutor

public SecurityAwareStripedThreadPoolExecutor(IgniteSecurity security,
                                              int concurrentLvl,
                                              String igniteInstanceName,
                                              String threadNamePrefix,
                                              Thread.UncaughtExceptionHandler eHnd,
                                              boolean allowCoreThreadTimeOut,
                                              long keepAliveTime)

Method Detail

execute

public void execute(Runnable task,
                    int idx)

Executes the given command at some time in the future. The command with the same index will be executed in the same thread.

Overrides:

execute in class IgniteStripedThreadPoolExecutor

Parameters:

task - the runnable task

idx - Striped index.