Package io.github.ai4ci.flow

Class QueueWriter

java.lang.Object

java.lang.Thread

io.github.ai4ci.flow.QueueWriter

All Implemented Interfaces:

CSVWriter.Queue, Runnable

public class QueueWriter
extends Thread
implements CSVWriter.Queue

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
QueueWriter(File file, int size, String name, String headers)

Method Summary

Modifier and Type	Method	Description
void	flush()
void	halt()
boolean	isWaiting()
String	report()
void	run()
void	submit(String item)

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, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.github.ai4ci.flow.CSVWriter.Queue

join

Constructor Details

QueueWriter

public QueueWriter(File file,
 int size,
 String name,
 String headers)
            throws IOException

Throws:

IOException

Method Details

submit

public void submit(String item)

Specified by:

submit in interface CSVWriter.Queue

halt

public void halt()

Specified by:

halt in interface CSVWriter.Queue

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

flush

public void flush()

Specified by:

flush in interface CSVWriter.Queue

isWaiting

public boolean isWaiting()

Specified by:

isWaiting in interface CSVWriter.Queue

report

public String report()

Specified by:

report in interface CSVWriter.Queue