Package com.univocity.parsers.common.input.concurrent

Class ConcurrentCharLoader

java.lang.Object

com.univocity.parsers.common.input.concurrent.ConcurrentCharLoader

All Implemented Interfaces:

Runnable

class ConcurrentCharLoader
extends Object
implements Runnable

A concurrent character loader for loading a pool of CharBucket instances using a Reader in a separate thread

See Also:

• ConcurrentCharInputReader
• CharBucket
• Entry

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	active
private Thread	activeExecution
private final ArrayBlockingQueue<Object>	buckets
private final boolean	closeOnStop
private Entry<CharBucket>	currentBucket
private final CharBucket	end
private Exception	error
private boolean	finished
private final FixedInstancePool<CharBucket>	instances
(package private) Reader	reader

Constructor Summary

Constructors

Constructor	Description
ConcurrentCharLoader(Reader reader, int bucketSize, int bucketQuantity, boolean closeOnStop)	Creates a FixedInstancePool with a given amount of CharBucket instances and starts a thread to fill each one.

Method Summary

Modifier and Type	Method	Description
CharBucket	nextBucket()	Returns the next available bucket.
private int	readBucket()
(package private) void	reportError()
void	run()	The CharBucket loading process that executes in parallel until the input is completely read.
private void	setError(Exception e)
void	stopReading()	Stops the CharBucket loading process and closes the reader provided in the constructor of this class

Methods inherited from class java.lang.Object

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

Field Details

buckets

private final ArrayBlockingQueue<Object> buckets

end

private final CharBucket end

instances

private final FixedInstancePool<CharBucket> instances

currentBucket

private Entry<CharBucket> currentBucket

finished

private boolean finished

active

private boolean active

reader

Reader reader

activeExecution

private Thread activeExecution

error

private Exception error

closeOnStop

private final boolean closeOnStop

Constructor Details

ConcurrentCharLoader

public ConcurrentCharLoader(Reader reader,
 int bucketSize,
 int bucketQuantity,
 boolean closeOnStop)

Creates a FixedInstancePool with a given amount of CharBucket instances and starts a thread to fill each one.

Parameters:

reader - The source of characters to extract and fill CharBucket instances

bucketSize - The size of each individual CharBucket

bucketQuantity - The number of CharBucket instances used to extract characters from the given reader.

closeOnStop - Indicates whether to automatically close the input when stopReading() is called

Method Details

readBucket

private int readBucket()
                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

run

public void run()

The CharBucket loading process that executes in parallel until the input is completely read. Once the end of the input is reached, the Reader instance provided in the constructor is closed.

Specified by:

run in interface Runnable

setError

private void setError(Exception e)

nextBucket

public CharBucket nextBucket()

Returns the next available bucket. Blocks until a bucket is made available or the reading process stops.

Returns:

the next available bucket.

stopReading

public void stopReading()

Stops the CharBucket loading process and closes the reader provided in the constructor of this class

reportError

void reportError()