Class Converter

java.lang.Object

java.lang.Thread

Converter

All Implemented Interfaces:

java.lang.Runnable

public class Converter
extends java.lang.Thread

An instance of this class is a thread for converting an input file or SQL query to the resulting JSON.

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.atomic.AtomicBoolean	active True, if thread is active, otherwise false.
private java.util.concurrent.locks.Lock	entryLock "Mutex" for the producer–consumer.
private java.util.concurrent.Semaphore	inputAvailable Semaphore for the existence of an input requirement (producer-consumer).
private java.io.File	inputFile Variable for input file.
private Database.DB_Messenger	query Variable for SQL query.
private IConversionResults	ui The user interface that this thread created.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Converter(IConversionResults ui) Initializes instance attributes.

Method Summary

Modifier and Type	Method and Description
private void	convert(byte[] buffer, java.lang.StringBuilder json) Converts the input byte buffer given by parameter into json which is saved using the StringBuilder.
void	end() End of the thread run.
private byte[]	getBytes(java.io.File file, Database.DB_Messenger query) Retrieve data from the file or database.
boolean	getInput(java.util.concurrent.atomic.AtomicReference<java.io.File> inputFile, java.util.concurrent.atomic.AtomicReference<Database.DB_Messenger> query) Get a request to process the input.
void	run()
void	setInput(java.io.File inputFile, Database.DB_Messenger query) Sets the input processing request.

Methods inherited from class java.lang.Thread

activeCount, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, checkAccess, 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

Field Detail

ui

private IConversionResults ui

The user interface that this thread created.

active

private java.util.concurrent.atomic.AtomicBoolean active

True, if thread is active, otherwise false. Thread-safe variable.

entryLock

private java.util.concurrent.locks.Lock entryLock

"Mutex" for the producer–consumer.

inputAvailable

private java.util.concurrent.Semaphore inputAvailable

Semaphore for the existence of an input requirement (producer-consumer).

inputFile

private java.io.File inputFile

Variable for input file. Set by the user.

query

private Database.DB_Messenger query

Variable for SQL query. Set by the user.

Constructor Detail

Converter

public Converter(IConversionResults ui)

Initializes instance attributes.

Parameters:

ui - instance of the Window or CLI.

Method Detail

end

public void end()

End of the thread run.

setInput

public void setInput(java.io.File inputFile,
                     Database.DB_Messenger query)

Sets the input processing request. One of the input parameters should be null.

Parameters:

inputFile - input file.

query - SQL query.

getInput

public boolean getInput(java.util.concurrent.atomic.AtomicReference<java.io.File> inputFile,
                        java.util.concurrent.atomic.AtomicReference<Database.DB_Messenger> query)

Get a request to process the input.

Parameters:

inputFile - variable for input file "passing by reference".

query - variable for SQL query "passing by reference".

Returns:

true, when there is a request to process the input.

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

getBytes

private byte[] getBytes(java.io.File file,
                        Database.DB_Messenger query)
                 throws java.lang.Exception

Retrieve data from the file or database. One parameter should always be null.

Parameters:

file - input file.

query - input query.

Returns:

read data in a byte array.

Throws:

java.lang.Exception - if an error occurs while retrieving data.

convert

private void convert(byte[] buffer,
                     java.lang.StringBuilder json)
              throws java.lang.Exception

Converts the input byte buffer given by parameter into json which is saved using the StringBuilder.

Parameters:

buffer - byte array buffer for input data of serialized object.

json - StringBuilder to which will be saved the json result.

Throws:

java.lang.Exception - if an error occurred during deserialization.