Package one.microstream.storage.types
Class StorageChannelSynchronizingTask.AbstractCompletingTask<R>
java.lang.Object
one.microstream.storage.types.StorageTask.Abstract
one.microstream.storage.types.StorageChannelTask.Abstract<R>
one.microstream.storage.types.StorageChannelSynchronizingTask.AbstractCompletingTask<R>
- All Implemented Interfaces:
StorageChannelSynchronizingTask
,StorageChannelTask
,StorageTask
- Direct Known Subclasses:
StorageChannelSynchronizingTask.AbstractCompletingTask.Dummy
,StorageChannelTaskInitialize.Default
,StorageChannelTaskShutdown.Default
,StorageRequestTaskCacheCheck.Default
,StorageRequestTaskCreateStatistics.Default
,StorageRequestTaskExportChannels.Default
,StorageRequestTaskExportEntitiesByType.Default
,StorageRequestTaskFileCheck.Default
,StorageRequestTaskGarbageCollection.Default
,StorageRequestTaskImportData.Default
,StorageRequestTaskStoreEntities.Default
- Enclosing interface:
- StorageChannelSynchronizingTask
public abstract static class StorageChannelSynchronizingTask.AbstractCompletingTask<R> extends StorageChannelTask.Abstract<R> implements StorageChannelSynchronizingTask
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
StorageChannelSynchronizingTask.AbstractCompletingTask.Dummy
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannelSynchronizingTask
StorageChannelSynchronizingTask.AbstractCompletingTask<R>
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageChannelTask
StorageChannelTask.Abstract<R>
Nested classes/interfaces inherited from interface one.microstream.storage.types.StorageTask
StorageTask.Abstract, StorageTask.DummyTask
-
Constructor Summary
Constructors Constructor Description AbstractCompletingTask(long timestamp, int channelCount)
-
Method Summary
Modifier and Type Method Description protected void
complete(StorageChannel channel, R result)
protected void
fail(StorageChannel channel, R result)
protected R
internalProcessBy(StorageChannel channel)
protected void
postCompletionSuccess(StorageChannel channel, R result)
protected void
succeed(StorageChannel channel, R result)
Methods inherited from class one.microstream.storage.types.StorageChannelTask.Abstract
addProblem, channelCount, cleanUp, finishProcessing, hasProblems, incrementCompletionProgress, incrementProcessingProgress, isComplete, isProcessed, problemForChannel, problems, processBy, waitOnCompletion, waitOnProcessing
Methods inherited from class one.microstream.storage.types.StorageTask.Abstract
awaitNext, next, setNext, timestamp
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface one.microstream.storage.types.StorageChannelSynchronizingTask
incrementProcessingProgress, isProcessed, waitOnProcessing
Methods inherited from interface one.microstream.storage.types.StorageChannelTask
addProblem, incrementCompletionProgress
Methods inherited from interface one.microstream.storage.types.StorageTask
awaitNext, hasProblems, isComplete, next, problemForChannel, problems, processBy, setNext, timestamp, waitOnCompletion
-
Constructor Details
-
AbstractCompletingTask
public AbstractCompletingTask(long timestamp, int channelCount)
-
-
Method Details
-
succeed
-
fail
-
postCompletionSuccess
- Throws:
InterruptedException
-
internalProcessBy
- Specified by:
internalProcessBy
in classStorageChannelTask.Abstract<R>
-
complete
- Specified by:
complete
in classStorageChannelTask.Abstract<R>
- Throws:
InterruptedException
-