teetime.framework

Class AbstractPipe<T>

java.lang.Object

teetime.framework.AbstractPipe<T>

Type Parameters:

T - the type of the elements which this pipe should transfer.

All Implemented Interfaces:

IPipe<T>

Direct Known Subclasses:

AbstractSynchedPipe, AbstractSynchedPipe, AbstractUnsynchedPipe, AbstractUnsynchedPipe

public abstract class AbstractPipe<T>
extends Object
implements IPipe<T>

Represents an abstract implementation of an IPipe.

Author:

Christian Wulf (chw)

Field Summary

Fields

Modifier and Type	Field and Description
protected AbstractStage	cachedTargetStage

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)

Method Summary

Modifier and Type	Method and Description
AbstractStage	getCachedTargetStage() Performance cache: Avoids the following method chain
protected PipeScheduler	getScheduler()
OutputPort<? extends T>	getSourcePort()
InputPort<T>	getTargetPort()
boolean	hasMore()
void	setScheduler(PipeScheduler scheduler)
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface teetime.framework.pipe.IPipe

add, addNonBlocking, capacity, close, isClosed, isEmpty, removeLast, reportNewElement, sendSignal, size, waitForStartSignal

Field Detail

cachedTargetStage

protected final AbstractStage cachedTargetStage

Constructor Detail

AbstractPipe

protected AbstractPipe(OutputPort<? extends T> sourcePort,
                       InputPort<T> targetPort)

Method Detail

getSourcePort

public final OutputPort<? extends T> getSourcePort()

Specified by:

getSourcePort in interface IPipe<T>

Returns:

the output port that is connected to the pipe.

getTargetPort

public final InputPort<T> getTargetPort()

Specified by:

getTargetPort in interface IPipe<T>

Returns:

the input port that is connected to the pipe.

hasMore

public final boolean hasMore()

Specified by:

hasMore in interface IPipe<T>

Returns:

true if the pipe is not empty, that is, if the pipe contains at least one element.

getCachedTargetStage

public AbstractStage getCachedTargetStage()

Performance cache: Avoids the following method chain

 this.getTargetPort().getOwningStage()
 

getScheduler

protected PipeScheduler getScheduler()

setScheduler

public void setScheduler(PipeScheduler scheduler)

Specified by:

setScheduler in interface IPipe<T>

toString

public String toString()

Overrides:

toString in class Object