Uses of Class
org.apache.ignite.internal.util.StripedExecutor

Packages that use StripedExecutor

Package	Description
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.managers	TODO.
org.apache.ignite.internal.managers.systemview
org.apache.ignite.internal.processors.cache.persistence	This package contain cache with persistence implementation.
org.apache.ignite.internal.processors.cache.persistence.checkpoint
org.apache.ignite.internal.processors.cache.persistence.wal.reader
org.apache.ignite.internal.processors.metric

Uses of StripedExecutor in org.apache.ignite.internal

Fields in org.apache.ignite.internal declared as StripedExecutor

Modifier and Type	Field and Description
protected StripedExecutor	GridKernalContextImpl.stripedExecSvc

Methods in org.apache.ignite.internal that return StripedExecutor

Modifier and Type	Method and Description
StripedExecutor	GridKernalContext.getDataStreamerExecutorService() Executor service that is in charge of processing data stream messages.
StripedExecutor	GridKernalContextImpl.getDataStreamerExecutorService() Executor service that is in charge of processing data stream messages.
StripedExecutor	GridKernalContext.getStripedExecutorService() Executor service that is in charge of processing internal system messages in stripes (dedicated threads).
StripedExecutor	GridKernalContextImpl.getStripedExecutorService() Executor service that is in charge of processing internal system messages in stripes (dedicated threads).

Methods in org.apache.ignite.internal with parameters of type StripedExecutor

Modifier and Type

Method and Description

void

IgniteKernal.start(IgniteConfiguration cfg, ExecutorService utilityCachePool, ExecutorService execSvc, ExecutorService svcExecSvc, ExecutorService sysExecSvc, StripedExecutor stripedExecSvc, ExecutorService p2pExecSvc, ExecutorService mgmtExecSvc, StripedExecutor dataStreamExecSvc, ExecutorService restExecSvc, ExecutorService affExecSvc, @Nullable ExecutorService idxExecSvc, @Nullable ExecutorService buildIdxExecSvc, IgniteStripedThreadPoolExecutor callbackExecSvc, ExecutorService qryExecSvc, ExecutorService schemaExecSvc, ExecutorService rebalanceExecSvc, IgniteStripedThreadPoolExecutor rebalanceStripedExecSvc, @Nullable Map<String,? extends ExecutorService> customExecSvcs, GridAbsClosure errHnd, WorkersRegistry workerRegistry, Thread.UncaughtExceptionHandler hnd, TimeBag startTimer)

Constructors in org.apache.ignite.internal with parameters of type StripedExecutor

Constructor and Description
GridKernalContextImpl(GridLoggerProxy log, IgniteEx grid, IgniteConfiguration cfg, GridKernalGateway gw, ExecutorService utilityCachePool, ExecutorService execSvc, ExecutorService svcExecSvc, ExecutorService sysExecSvc, StripedExecutor stripedExecSvc, ExecutorService p2pExecSvc, ExecutorService mgmtExecSvc, StripedExecutor dataStreamExecSvc, ExecutorService restExecSvc, ExecutorService affExecSvc, @Nullable ExecutorService idxExecSvc, @Nullable ExecutorService buildIdxExecSvc, IgniteStripedThreadPoolExecutor callbackExecSvc, ExecutorService qryExecSvc, ExecutorService schemaExecSvc, ExecutorService rebalanceExecSvc, IgniteStripedThreadPoolExecutor rebalanceStripedExecSvc, @Nullable Map<String,? extends ExecutorService> customExecSvcs, List<PluginProvider> plugins, IgnitePredicate<String> clsFilter, WorkersRegistry workerRegistry, Thread.UncaughtExceptionHandler hnd, LongJVMPauseDetector pauseDetector) Creates new kernal context.
StripedExecutorMXBeanAdapter(StripedExecutor exec)

Uses of StripedExecutor in org.apache.ignite.internal.managers

Methods in org.apache.ignite.internal.managers with parameters of type StripedExecutor

Modifier and Type

Method and Description

void

IgniteMBeansManager.registerMBeansAfterNodeStarted(ExecutorService utilityCachePool, ExecutorService execSvc, ExecutorService svcExecSvc, ExecutorService sysExecSvc, StripedExecutor stripedExecSvc, ExecutorService p2pExecSvc, ExecutorService mgmtExecSvc, StripedExecutor dataStreamExecSvc, ExecutorService restExecSvc, ExecutorService affExecSvc, @Nullable ExecutorService idxExecSvc, IgniteStripedThreadPoolExecutor callbackExecSvc, ExecutorService qryExecSvc, ExecutorService schemaExecSvc, ExecutorService rebalanceExecSvc, IgniteStripedThreadPoolExecutor rebalanceStripedExecSvc, @Nullable Map<String,? extends ExecutorService> customExecSvcs, WorkersRegistry workersRegistry) Registers kernal MBeans (for kernal, metrics, thread pools) after node start.

Uses of StripedExecutor in org.apache.ignite.internal.managers.systemview

Methods in org.apache.ignite.internal.managers.systemview with parameters of type StripedExecutor

Modifier and Type	Method and Description
void	GridSystemViewManager.registerThreadPools(StripedExecutor stripedExecSvc, StripedExecutor dataStreamExecSvc) Registers system views for a striped thread pools.

Uses of StripedExecutor in org.apache.ignite.internal.processors.cache.persistence

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type StripedExecutor

Modifier and Type	Method and Description
void	GridCacheDatabaseSharedManager.stripedApply(Runnable run, int grpId, int partId, StripedExecutor exec, Semaphore semaphore)
void	GridCacheDatabaseSharedManager.stripedApplyPage(Consumer<PageMemoryEx> consumer, int grpId, int partId, StripedExecutor exec, Semaphore semaphore)

Uses of StripedExecutor in org.apache.ignite.internal.processors.cache.persistence.checkpoint

Methods in org.apache.ignite.internal.processors.cache.persistence.checkpoint with parameters of type StripedExecutor

Modifier and Type	Method and Description
void	CheckpointManager.finalizeCheckpointOnRecovery(long ts, UUID id, WALPointer ptr, StripedExecutor exec)
void	LightweightCheckpointManager.finalizeCheckpointOnRecovery(long ts, UUID id, WALPointer ptr, StripedExecutor exec)
void	Checkpointer.finalizeCheckpointOnRecovery(long cpTs, UUID cpId, WALPointer walPtr, StripedExecutor exec)
void	CheckpointWorkflow.finalizeCheckpointOnRecovery(long cpTs, UUID cpId, WALPointer walPtr, StripedExecutor exec, CheckpointPagesWriterFactory checkpointPagesWriterFactory) This method makes sense if node was stopped during the checkpoint(Start marker was written to disk while end marker are not).

Uses of StripedExecutor in org.apache.ignite.internal.processors.cache.persistence.wal.reader

Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that return StripedExecutor

Modifier and Type	Method and Description
StripedExecutor	StandaloneGridKernalContext.getDataStreamerExecutorService() Executor service that is in charge of processing data stream messages.
StripedExecutor	StandaloneGridKernalContext.getStripedExecutorService() Executor service that is in charge of processing internal system messages in stripes (dedicated threads).

Uses of StripedExecutor in org.apache.ignite.internal.processors.metric

Methods in org.apache.ignite.internal.processors.metric with parameters of type StripedExecutor

Modifier and Type

Method and Description

void

GridMetricManager.registerThreadPools(ExecutorService utilityCachePool, ExecutorService execSvc, ExecutorService svcExecSvc, ExecutorService sysExecSvc, StripedExecutor stripedExecSvc, ExecutorService p2pExecSvc, ExecutorService mgmtExecSvc, StripedExecutor dataStreamExecSvc, ExecutorService restExecSvc, ExecutorService affExecSvc, @Nullable ExecutorService idxExecSvc, IgniteStripedThreadPoolExecutor callbackExecSvc, ExecutorService qryExecSvc, ExecutorService schemaExecSvc, ExecutorService rebalanceExecSvc, IgniteStripedThreadPoolExecutor rebalanceStripedExecSvc, @Nullable Map<String,? extends ExecutorService> customExecSvcs) Registers all metrics for thread pools.