com.bigdata.rdf.task

Class ApiTaskForJournal<T>

java.lang.Object

com.bigdata.journal.AbstractTask<T>

com.bigdata.rdf.task.ApiTaskForJournal<T>

Type Parameters:

T -

All Implemented Interfaces:

ITask<T>, Callable<T>

public class ApiTaskForJournal<T>
extends AbstractTask<T>

Wrapper for a task to be executed on the IConcurrencyManager of a Journal.

Author:

Bryan Thompson

See Also:

HA doLocalAbort() should interrupt NSS requests and AbstractTasks , Concurrent unisolated operations against multiple KBs

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.journal.AbstractTask

AbstractTask.DelegateTask<T>, AbstractTask.InnerReadWriteTxServiceCallable<T>, AbstractTask.InnerWriteServiceCallable<T>, AbstractTask.ResubmitException

Field Summary

Fields inherited from class com.bigdata.journal.AbstractTask

checkpointNanoTime, concurrencyManager, isReadWriteTx, log, nanoTime_assignedWorker, nanoTime_beginWork, nanoTime_finishedWork, nanoTime_submitTask, readOnly, resourceManager, taskCounters, timestamp, transactionManager, tx

Constructor Summary

Constructors

Constructor and Description
ApiTaskForJournal(IConcurrencyManager concurrencyManager, long timestamp, String[] resource, IApiTask<T> delegate)

Method Summary

Methods

Modifier and Type	Method and Description
protected T	doTask() Implement the task behavior here.
String	toString() Returns Task{taskName,timestamp,elapsed,resource[]}

Methods inherited from class com.bigdata.journal.AbstractTask

assertResource, assertRunning, assertUnisolated, call, clearLoggingContext, dropIndex, getCommitTime, getIndex, getJournal, getOnlyResource, getResource, getResourceManager, getTaskCounters, getTaskName, getTimestamp, isResource, registerIndex, setupLoggingContext

Methods inherited from class java.lang.Object

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

Constructor Detail

ApiTaskForJournal

public ApiTaskForJournal(IConcurrencyManager concurrencyManager,
                 long timestamp,
                 String[] resource,
                 IApiTask<T> delegate)

Method Detail

toString

public String toString()

Description copied from class: AbstractTask

Returns Task{taskName,timestamp,elapsed,resource[]}

Specified by:

toString in interface ITask<T>

Overrides:

toString in class AbstractTask<T>

doTask

protected T doTask()
            throws Exception

Description copied from class: AbstractTask

Implement the task behavior here.

Note: Long-running implementations MUST periodically test Thread.interrupted() and MUST throw an exception, such as InterruptedException, if they are interrupted. This behavior allows tasks to be canceled in a timely manner.

If you ignore or fail to test Thread.interrupted() then your task CAN NOT be aborted. If it is Future.cancel(boolean) with false then the task will run to completion even though it has been cancelled (but the Future will appear to have been cancelled).

If you simply return rather than throwing an exception then the WriteExecutorService will assume that your task completed and your (partial) results will be made restart-safe at the next commit!

Specified by:

doTask in class AbstractTask<T>

Returns:

The object that will be returned by AbstractTask.call() iff the operation succeeds.

Throws:

Exception - The exception that will be thrown by AbstractTask.call() iff the operation fails.

InterruptedException - This exception SHOULD be thrown if Thread.interrupted() becomes true during execution.