Class CacheStripedExecutor
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.persistence.CacheStripedExecutor
-
public class CacheStripedExecutor extends Object
Wrapper overStripedExecutor, that groups submitted tasks by cache group and partition.
-
-
Constructor Summary
Constructors Constructor Description CacheStripedExecutor(StripedExecutor exec)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidawaitApplyComplete()Awaits while all submitted tasks completed.booleanerror()StripedExecutorexecutor()voidonError(IgniteCheckedException e)voidsubmit(Runnable task, int grpId, int partId)Submit task to striped executor.
-
-
-
Constructor Detail
-
CacheStripedExecutor
public CacheStripedExecutor(StripedExecutor exec)
-
-
Method Detail
-
submit
public void submit(Runnable task, int grpId, int partId)
Submit task to striped executor.- Parameters:
task- Runnable task.grpId- Group ID.partId- Partition ID.
-
awaitApplyComplete
public void awaitApplyComplete() throws IgniteCheckedExceptionAwaits while all submitted tasks completed.- Throws:
IgniteCheckedException- if any os submitted tasks failed.
-
error
public boolean error()
- Returns:
trueif any of submitted tasks failed.
-
onError
public void onError(IgniteCheckedException e)
- Parameters:
e- Error appeared during submitted task execution.
-
executor
public StripedExecutor executor()
- Returns:
- Underlying striped executor.
-
-