proai.cache
Class Updater

java.lang.Object
  java.lang.Thread
      proai.cache.Updater

All Implemented Interfaces:

java.lang.Runnable

public class Updater
extends java.lang.Thread

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Updater(OAIDriver driver, RecordCache cache, RCDatabase db, RCDisk disk, int pollSeconds, int maxWorkers, int maxWorkBatchSize, int maxFailedRetries, int maxCommitQueueSize, int maxRecordsPerTransaction, net.sf.bvalid.Validator validator)

Method Summary

protected boolean	anyWorkersAreRunning()
protected java.util.List<QueueItem>	getNextBatch(java.util.List<QueueItem> finishedItems)
protected void	handleCommitException(java.lang.Throwable th) Handle an exception encountered by currently-running Committer while committing.
protected boolean	processingShouldStop()
void	run()
void	shutdown(boolean immediate) Signal that the thread should be shut down and wait for it to finish.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

Updater

public Updater(OAIDriver driver,
               RecordCache cache,
               RCDatabase db,
               RCDisk disk,
               int pollSeconds,
               int maxWorkers,
               int maxWorkBatchSize,
               int maxFailedRetries,
               int maxCommitQueueSize,
               int maxRecordsPerTransaction,
               net.sf.bvalid.Validator validator)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

shutdown

public void shutdown(boolean immediate)

Signal that the thread should be shut down and wait for it to finish. If immediate is true, abort the update cycle if it's running.

handleCommitException

protected void handleCommitException(java.lang.Throwable th)

Handle an exception encountered by currently-running Committer while committing.

getNextBatch

protected java.util.List<QueueItem> getNextBatch(java.util.List<QueueItem> finishedItems)

processingShouldStop

protected boolean processingShouldStop()

anyWorkersAreRunning

protected boolean anyWorkersAreRunning()