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

Class SecurityAwareStripedExecutor

java.lang.Object

org.apache.ignite.internal.util.StripedExecutor

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

All Implemented Interfaces:

Executor, ExecutorService, MetricsAwareExecutorService

public class SecurityAwareStripedExecutor
extends StripedExecutor

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

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.util.StripedExecutor

StripedExecutor.Stripe

Field Summary

Fields inherited from class org.apache.ignite.internal.util.StripedExecutor

DFLT_DATA_STREAMING_EXECUTOR_SERVICE_TASKS_STEALING_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
SecurityAwareStripedExecutor(IgniteSecurity security, int cnt, String igniteInstanceName, String poolName, IgniteLogger log, IgniteInClosure<Throwable> errHnd, boolean stealTasks, GridWorkerListener gridWorkerLsnr, long failureDetectionTimeout)
SecurityAwareStripedExecutor(IgniteSecurity security, int cnt, String igniteInstanceName, String poolName, IgniteLogger log, IgniteInClosure<Throwable> errHnd, GridWorkerListener gridWorkerLsnr, long failureDetectionTimeout)

Method Summary

Modifier and Type	Method and Description
void	execute(int idx, Runnable cmd) Execute command.
void	execute(@NotNull Runnable cmd)

Methods inherited from class org.apache.ignite.internal.util.StripedExecutor

activeStripesCount, awaitComplete, awaitTermination, completedTasks, detectStarvation, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, queueSize, queueStripeSize, registerMetrics, shutdown, shutdownNow, stop, stripes, stripesActiveStatuses, stripesCompletedTasks, stripesCount, stripesQueueSizes, submit, submit, submit, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SecurityAwareStripedExecutor

public SecurityAwareStripedExecutor(IgniteSecurity security,
                                    int cnt,
                                    String igniteInstanceName,
                                    String poolName,
                                    IgniteLogger log,
                                    IgniteInClosure<Throwable> errHnd,
                                    GridWorkerListener gridWorkerLsnr,
                                    long failureDetectionTimeout)

SecurityAwareStripedExecutor

public SecurityAwareStripedExecutor(IgniteSecurity security,
                                    int cnt,
                                    String igniteInstanceName,
                                    String poolName,
                                    IgniteLogger log,
                                    IgniteInClosure<Throwable> errHnd,
                                    boolean stealTasks,
                                    GridWorkerListener gridWorkerLsnr,
                                    long failureDetectionTimeout)

Method Detail

execute

public void execute(int idx,
                    Runnable cmd)

Execute command.

Overrides:

execute in class StripedExecutor

Parameters:

idx - Index.

cmd - Command.

execute

public void execute(@NotNull
                    @NotNull Runnable cmd)

Specified by:

execute in interface Executor

Overrides:

execute in class StripedExecutor