AsyncMultiReader.ReaderThread (Data Pipeline JavaDoc)

java.lang.Object

java.lang.Thread

com.northconcepts.datapipeline.core.AsyncMultiReader.ReaderThread

All Implemented Interfaces:: Runnable

Enclosing class:: AsyncMultiReader

public class AsyncMultiReader.ReaderThread extends Thread

Thread that opens one source reader, copies its records into the AsyncMultiReader's buffer and closes it.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread
Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler
Field Summary

Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Method Summary

Modifier and Type

Method

Description

Throwable

getException()

Returns the exception that stopped this thread or null if it ended normally.

DataReader

getReader()

boolean

isFinished()

boolean

isNotFinished()

void

run()

AsyncMultiReader.ReaderThread

shutdown()

Asks this thread to stop by marking it finished and interrupting it; does nothing if it is already finished.

String

toString()

Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, yield

Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details
- getReader
  
  public DataReader getReader()
- isFinished
  
  public boolean isFinished()
- isNotFinished
  
  public boolean isNotFinished()
- getException
  
  public Throwable getException()
  
  Returns the exception that stopped this thread or null if it ended normally.
- shutdown
  
  public AsyncMultiReader.ReaderThread shutdown()
  
  Asks this thread to stop by marking it finished and interrupting it; does nothing if it is already finished.
- run
  
  public void run()
  
  Specified by:
  
  run in interface Runnable
  
  Overrides:
  
  run in class Thread
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Thread