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

java.lang.Object
  java.lang.Thread
      org.opends.server.api.DirectoryThread
          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