com.ibm.di.queue
Class MemBufferLoaderThread

java.lang.Object
  java.lang.Thread
      com.ibm.di.queue.MemBufferThread
          com.ibm.di.queue.MemBufferLoaderThread

All Implemented Interfaces:

Runnable

public class MemBufferLoaderThread
extends MemBufferThread

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class com.ibm.di.queue.MemBufferThread

actionListener, bDirty, connect, memQ, size

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

MemBufferLoaderThread(MemQ s, int size)
Constructor

Method Summary

void	emptySystemStore() Deletes contents of table associated with queue
void	run() thread run method loads pages from system store into the memq
void	setThreshold(int threshold) setThreshold set the size to be the threshold value this is called when threshold is calculated based on te size of first page written

Methods inherited from class com.ibm.di.queue.MemBufferThread

addActionListener, fireListener, Initialize, isStoreEmpty, removeActionListener, terminate

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

MemBufferLoaderThread

public MemBufferLoaderThread(MemQ s,
                             int size)

Constructor

Parameters:

s - memq into which pages have to be loaded from the system store

size - threshold

Method Detail

setThreshold

public void setThreshold(int threshold)

setThreshold set the size to be the threshold value this is called when threshold is calculated based on te size of first page written

Parameters:

threshold - threshold value

run

public void run()

thread run method loads pages from system store into the memq

Specified by:

run in interface Runnable

Overrides:

run in class Thread

emptySystemStore

public void emptySystemStore()

Deletes contents of table associated with queue