marytts.util.data

Class ProducingDoubleDataSource

java.lang.Object

marytts.util.data.BaseDoubleDataSource

marytts.util.data.BufferedDoubleDataSource

marytts.util.data.ProducingDoubleDataSource

All Implemented Interfaces:

Runnable, DoubleDataSource

Direct Known Subclasses:

HTSVocoder.HTSVocoderDataProducer

public abstract class ProducingDoubleDataSource
extends BufferedDoubleDataSource
implements Runnable

Author:

marc

Field Summary

Fields

Modifier and Type	Field and Description
protected ArrayBlockingQueue<Double>	queue

Fields inherited from class marytts.util.data.BufferedDoubleDataSource

buf, dataProcessor, DEFAULT_BUFFERSIZE, readPos, writePos

Fields inherited from class marytts.util.data.BaseDoubleDataSource

dataLength, inputSource

Fields inherited from interface marytts.util.data.DoubleDataSource

NOT_SPECIFIED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ProducingDoubleDataSource()
protected	ProducingDoubleDataSource(InlineDataProcessor dataProcessor)
protected	ProducingDoubleDataSource(long numDataThatWillBeProduced)
protected	ProducingDoubleDataSource(long numDataThatWillBeProduced, InlineDataProcessor dataProcessor)

Method Summary

Methods

Modifier and Type	Method and Description
int	available() The number of doubles that can currently be read from this double data source without blocking.
boolean	hasMoreData() Whether or not any more data can be read from this data source.
protected void	putEndOfStream()
void	putOneDataPoint(double value) The producing thread tries to put ont data item into the queue.
protected boolean	readIntoBuffer(int minLength) Attempt to get more data from the input source.
abstract void	run() Subclasses must implement this method such that it produces data and sends it through putOneDataPoint(double).
void	start()

Methods inherited from class marytts.util.data.BufferedDoubleDataSource

bufferSpaceLeft, compact, currentlyInBuffer, getData, increaseBufferSize

Methods inherited from class marytts.util.data.BaseDoubleDataSource

getAllData, getData, getData, getDataLength

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected ArrayBlockingQueue<Double> queue

Constructor Detail

ProducingDoubleDataSource

protected ProducingDoubleDataSource()

ProducingDoubleDataSource

protected ProducingDoubleDataSource(long numDataThatWillBeProduced)

ProducingDoubleDataSource

protected ProducingDoubleDataSource(InlineDataProcessor dataProcessor)

ProducingDoubleDataSource

protected ProducingDoubleDataSource(long numDataThatWillBeProduced,
                         InlineDataProcessor dataProcessor)

Method Detail

start

public void start()

run

public abstract void run()

Subclasses must implement this method such that it produces data and sends it through putOneDataPoint(double). When all data is sent, the subclass must call putEndOfStream() exactly once.

Specified by:

run in interface Runnable

putOneDataPoint

public void putOneDataPoint(double value)

The producing thread tries to put ont data item into the queue.

Parameters:

value - value

Throws:

RuntimeException - runtime exception

putEndOfStream

protected void putEndOfStream()

hasMoreData

public boolean hasMoreData()

Description copied from class: BufferedDoubleDataSource

Whether or not any more data can be read from this data source.

Specified by:

hasMoreData in interface DoubleDataSource

Overrides:

hasMoreData in class BufferedDoubleDataSource

Returns:

true if another call to getData() will return data, false otherwise.

available

public int available()

Description copied from class: BufferedDoubleDataSource

The number of doubles that can currently be read from this double data source without blocking. This number can change over time.

Specified by:

available in interface DoubleDataSource

Overrides:

available in class BufferedDoubleDataSource

Returns:

the number of doubles that can currently be read without blocking

readIntoBuffer

protected boolean readIntoBuffer(int minLength)

Description copied from class: BufferedDoubleDataSource

Attempt to get more data from the input source. If less than this can be read, the possible amount will be read, but canReadMore() will return false afterwards.

Overrides:

readIntoBuffer in class BufferedDoubleDataSource

Parameters:

minLength - the amount of data to get from the input source

Returns:

true if the requested amount could be read, false if none or less data could be read.