com.bigdata.journal

Class AbstractTask.InnerWriteServiceCallable<T>

java.lang.Object

com.bigdata.journal.AbstractTask.DelegateTask<T>

com.bigdata.journal.AbstractTask.InnerWriteServiceCallable<T>

All Implemented Interfaces:

ITask<T>, Callable<T>

Enclosing class:

AbstractTask<T>

protected static class AbstractTask.InnerWriteServiceCallable<T>
extends AbstractTask.DelegateTask<T>

An instance of this class is used as the delegate to coordinate the acquisition of locks with the NonBlockingLockManager before the task can execute and to release locks after the task has completed (whether it succeeds or fails).

Note: This inner class delegates the execution of the task to AbstractTask.doTask() on the outer class.

Note: If there is only a single writer thread then the lock system essentially does nothing. When there are multiple writer threads the lock system imposes a partial ordering on the writers that ensures that writes on a given named index are single-threaded and that deadlocks do not prevent tasks from progressing. If there is strong lock contention then writers will be more or less serialized.

Author:

Bryan Thompson

Field Summary

Fields inherited from class com.bigdata.journal.AbstractTask.DelegateTask

delegate

Method Summary

Methods

Modifier and Type	Method and Description
T	call() Note: Locks on the named indices are ONLY held during this call.

Methods inherited from class com.bigdata.journal.AbstractTask.DelegateTask

getIndex, getJournal, getOnlyResource, getResource, getResourceManager, getTaskCounters, toString

Methods inherited from class java.lang.Object

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

Method Detail

call

public T call()
       throws Exception

Note: Locks on the named indices are ONLY held during this call.

Throws:

Exception