com.univocity.parsers.common.input.concurrent

Class ConcurrentCharLoader

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

class ConcurrentCharLoader
extends java.lang.Object
implements java.lang.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 and Description
private boolean	active
private java.lang.Thread	activeExecution
private java.util.concurrent.ArrayBlockingQueue<java.lang.Object>	buckets
private Entry<CharBucket>	currentBucket
private CharBucket	end
private java.lang.Exception	error
private boolean	finished
private FixedInstancePool<CharBucket>	instances
(package private) BomInput.BytesProcessedNotification	notification
private java.io.Reader	reader

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
CharBucket	nextBucket() Returns the next available bucket.
(package private) void	reportError()
void	run() The CharBucket loading process that executes in parallel until the input is completely read.
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 Detail

buckets

private final java.util.concurrent.ArrayBlockingQueue<java.lang.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

private final java.io.Reader reader

activeExecution

private final java.lang.Thread activeExecution

error

private java.lang.Exception error

notification

BomInput.BytesProcessedNotification notification

Constructor Detail

ConcurrentCharLoader

public ConcurrentCharLoader(java.io.Reader reader,
                            int bucketSize,
                            int bucketQuantity)

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.

Method Detail

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 java.lang.Runnable

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()