edu.illinois.cs.cogcomp.core.algorithms

Class ProducerConsumer<T>

java.lang.Object

edu.illinois.cs.cogcomp.core.algorithms.ProducerConsumer<T>

Direct Known Subclasses:

PreExtractor, PruningPreExtractor, TextStatistics

public abstract class ProducerConsumer<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ProducerConsumer.Consumer
class	ProducerConsumer.Producer

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	activeConsumers
protected AtomicInteger	count
protected Iterator<T>	data
protected AtomicBoolean	done
protected int	numConsumers
protected BlockingQueue<T>	theQueue

Constructor Summary

Constructors

Constructor and Description
ProducerConsumer(Iterator<T> data, int numConsumers)

Method Summary

Modifier and Type	Method and Description
protected abstract void	consume(T ta)
protected abstract String	getStatus()
protected abstract void	initialize()
protected abstract boolean	prerequisiteCheck(T input)
protected abstract List<T>	process(T ta)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

numConsumers

protected int numConsumers

theQueue

protected BlockingQueue<T> theQueue

data

protected Iterator<T> data

done

protected AtomicBoolean done

count

protected AtomicInteger count

activeConsumers

protected AtomicInteger activeConsumers

Constructor Detail

ProducerConsumer

public ProducerConsumer(Iterator<T> data,
                        int numConsumers)

Method Detail

run

public void run()
         throws InterruptedException

Throws:

InterruptedException

initialize

protected abstract void initialize()

prerequisiteCheck

protected abstract boolean prerequisiteCheck(T input)

consume

protected abstract void consume(T ta)

getStatus

protected abstract String getStatus()

process

protected abstract List<T> process(T ta)