public class ThreadedFileIOBase
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private static ThreadedFileIOBase |
INSTANCE |
private boolean |
isThreadWaiting |
private long |
savedIOCounter |
private java.util.List<IThreadedFileIO> |
threadedIOQueue |
private long |
writeQueuedCounter |
Modifier | Constructor and Description |
---|---|
private |
ThreadedFileIOBase() |
Modifier and Type | Method and Description |
---|---|
static ThreadedFileIOBase |
getThreadedIOInstance() |
private void |
processQueue() |
void |
queueIO(IThreadedFileIO fileIo) |
void |
run() |
void |
waitForFinish() |
private static final ThreadedFileIOBase INSTANCE
private final java.util.List<IThreadedFileIO> threadedIOQueue
private volatile long writeQueuedCounter
private volatile long savedIOCounter
private volatile boolean isThreadWaiting
public static ThreadedFileIOBase getThreadedIOInstance()
public void run()
run
in interface java.lang.Runnable
private void processQueue()
public void queueIO(IThreadedFileIO fileIo)
public void waitForFinish() throws java.lang.InterruptedException
java.lang.InterruptedException