org.opends.server.backends.jeb.importLDIF
Class WorkThread

java.lang.Object
  extended by java.lang.Thread
      extended by org.opends.server.api.DirectoryThread
          extended by org.opends.server.backends.jeb.importLDIF.WorkThread
All Implemented Interfaces:
java.lang.Runnable

public class WorkThread
extends DirectoryThread

A thread to process import entries from a queue. Multiple instances of this class process entries from a single shared queue.


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
WorkThread(java.util.concurrent.BlockingQueue<WorkElement> workQueue, int threadNumber, BufferManager bufferMgr, RootContainer rootContainer)
          Create a work thread instance using the specified parameters.
 
Method Summary
 void run()
          Run the thread.
 
Methods inherited from class org.opends.server.api.DirectoryThread
getAssociatedTask, getCreationStackTrace, getDebugProperties, getParentThread, setAssociatedTask
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, 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
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

WorkThread

public WorkThread(java.util.concurrent.BlockingQueue<WorkElement> workQueue,
                  int threadNumber,
                  BufferManager bufferMgr,
                  RootContainer rootContainer)
Create a work thread instance using the specified parameters.

Parameters:
workQueue - The work queue to pull work off of.
threadNumber - The thread number.
bufferMgr - The buffer manager to use.
rootContainer - The root container.
Method Detail

run

public void run()
Run the thread. Read from item from queue and give it to the buffer manage, unless told to stop. Once stopped, ask buffer manager to flush and exit.

Specified by:
run in interface java.lang.Runnable
Overrides:
run in class java.lang.Thread