univocity-parsers 2.9.1 · com.univocity.parsers.common.input.concurrent.ConcurrentCharLoader

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

Field Summary

Modifier and Type	Field and 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
pack-priv Reader	reader

Constructor Summary

Access Constructor and Description

Access	Constructor and Description
public	ConcurrentCharLoader(Reader The source of characters to extract and fill `CharBucket` instances reader, final int The size of each individual `CharBucket` bucketSize, int The number of `CharBucket` instances used to extract characters from the given reader. bucketQuantity, boolean Indicates whether to automatically close the input when `stopReading()` is called closeOnStop) Creates a `FixedInstancePool` with a given amount of `CharBucket` instances and starts a thread to fill each one.

public

ConcurrentCharLoader(Reader

The source of characters to extract and fill CharBucket instances

reader, final int

The size of each individual CharBucket

bucketSize, int

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

bucketQuantity, boolean

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

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 and Description
public synchronized CharBucket	Returns: the next available bucket. nextBucket() Returns the next available bucket.
private int	readBucket()
pack-priv void	reportError()
public void	run() Implements java.lang.Runnable.run. The `CharBucket` loading process that executes in parallel until the input is completely read.
private void	setError(Exception e)
public void	stopReading() Stops the `CharBucket` loading process and closes the reader provided in the constructor of this class

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

active	back to summary
private boolean active

activeExecution	back to summary
private Thread activeExecution

buckets	back to summary
private final ArrayBlockingQueue<Object> buckets

closeOnStop	back to summary
private final boolean closeOnStop

currentBucket	back to summary
private Entry<CharBucket> currentBucket

end	back to summary
private final CharBucket end

error	back to summary
private Exception error

finished	back to summary
private boolean finished

instances	back to summary
private final FixedInstancePool<CharBucket> instances

reader	back to summary
pack-priv Reader reader

Constructor Detail

ConcurrentCharLoader back to summary

ConcurrentCharLoader	back to summary
public ConcurrentCharLoader(Reader reader, final 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:Reader The source of characters to extract and fill `CharBucket` instances bucketSize:int The size of each individual `CharBucket` bucketQuantity:int The number of `CharBucket` instances used to extract characters from the given reader. closeOnStop:boolean Indicates whether to automatically close the input when `stopReading()` is called

public ConcurrentCharLoader(Reader reader, final 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:Reader: The source of characters to extract and fill CharBucket instances
bucketSize:int: The size of each individual CharBucket
bucketQuantity:int: The number of CharBucket instances used to extract characters from the given reader.
closeOnStop:boolean: Indicates whether to automatically close the input when stopReading() is called

Method Detail

nextBucket	back to summary
public synchronized CharBucket nextBucket() Returns the next available bucket. Blocks until a bucket is made available or the reading process stops. Returns:CharBucket the next available bucket. Annotations @SuppressWarnings:unchecked

nextBucket

back to summary

public synchronized CharBucket nextBucket()

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

Returns:CharBucket

the next available bucket.

Annotations

@SuppressWarnings:unchecked

readBucket	back to summary
private int readBucket() throws IOException, InterruptedException

reportError	back to summary
pack-priv void reportError()

run back to summary

run	back to summary
public void run() Implements java.lang.Runnable.run. The `CharBucket` loading process that executes in parallel until the input is completely read. Once the end of the input is reached, the `java.io.Reader` instance provided in the constructor is closed. Annotations @Override

public void run()

Implements java.lang.Runnable.run.

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