Package org.apache.ignite.internal.util

Class StripedExecutor.Stripe

java.lang.Object

org.apache.ignite.internal.util.worker.GridWorker

org.apache.ignite.internal.util.StripedExecutor.Stripe

All Implemented Interfaces:

Runnable, WorkProgressDispatcher

Enclosing class:

StripedExecutor

public abstract static class StripedExecutor.Stripe
extends GridWorker

Stripe.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	idx
protected Thread	thread	Thread executing the loop.

Fields inherited from class org.apache.ignite.internal.util.worker.GridWorker

isCancelled

Constructor Summary

Constructors

Constructor	Description
Stripe(String igniteInstanceName, String poolName, int idx, IgniteLogger log, IgniteInClosure<Throwable> errHnd, GridWorkerListener gridWorkerLsnr, HistogramMetricImpl execTime)

Method Summary

Modifier and Type	Method	Description
void	body()	The implementation should provide the execution body for this runnable.
int	index()
abstract Queue<Runnable>	queue()
String	toString()

Methods inherited from class org.apache.ignite.internal.util.worker.GridWorker

blockingSectionBegin, blockingSectionEnd, cancel, cleanup, heartbeatTs, igniteInstanceName, isCancelled, isDone, join, name, onCancel, onCancelledBeforeWorkerScheduled, onIdle, run, runner, updateHeartbeat

Methods inherited from class java.lang.Object

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

Field Detail

idx

protected final int idx

thread

protected Thread thread

Thread executing the loop.

Constructor Detail

Stripe

public Stripe(String igniteInstanceName,
              String poolName,
              int idx,
              IgniteLogger log,
              IgniteInClosure<Throwable> errHnd,
              GridWorkerListener gridWorkerLsnr,
              HistogramMetricImpl execTime)

Parameters:

igniteInstanceName - Ignite instance name.

poolName - Pool name.

idx - Stripe index.

log - Logger.

errHnd - Exception handler.

gridWorkerLsnr - listener to link with stripe worker.

execTime - Task execution time consumer.

Method Detail

body

public void body()

The implementation should provide the execution body for this runnable.

Specified by:

body in class GridWorker

queue

public abstract Queue<Runnable> queue()

Returns:

Stripe queue.

index

public int index()

Returns:

Stripe index.

toString

public String toString()

Overrides:

toString in class GridWorker