teetime.framework.pipe

Class UnsynchedPipe<T>

java.lang.Object

teetime.framework.AbstractPipe<T>

teetime.framework.pipe.AbstractUnsynchedPipe<T>

teetime.framework.pipe.UnsynchedPipe<T>

All Implemented Interfaces:

IPipe<T>

public final class UnsynchedPipe<T>
extends AbstractUnsynchedPipe<T>

Field Summary

Fields inherited from class teetime.framework.AbstractPipe

cachedTargetStage

Constructor Summary

Constructors

Constructor and Description
UnsynchedPipe(OutputPort<? extends T> sourcePort, InputPort<T> targetPort)

Method Summary

Modifier and Type	Method and Description
void	add(Object element) Adds an element to the pipe.
boolean	addNonBlocking(Object element) Adds an element to the pipe.
int	capacity()
boolean	isEmpty() Checks whether the pipe is empty or not.
Object	removeLast() Retrieves and removes the last element from the pipe.
int	size()

Methods inherited from class teetime.framework.pipe.AbstractUnsynchedPipe

close, isClosed, reportNewElement, sendSignal, waitForStartSignal

Methods inherited from class teetime.framework.AbstractPipe

getCachedTargetStage, getScheduler, getSourcePort, getTargetPort, hasMore, setScheduler, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

UnsynchedPipe

public UnsynchedPipe(OutputPort<? extends T> sourcePort,
                     InputPort<T> targetPort)

Method Detail

add

public void add(Object element)

Description copied from interface: IPipe

Adds an element to the pipe. This method does not return anything because it should guarantee element delivery (as opposed to IPipe.addNonBlocking(Object)). If it cannot guarantee element delivery in some special situation, it then must throw an exception.

Parameters:

element - to be added

addNonBlocking

public boolean addNonBlocking(Object element)

Description copied from interface: IPipe

Adds an element to the pipe.

Parameters:

element - Element which will be added

Returns:

true if the element could be added, false otherwise

removeLast

public Object removeLast()

Description copied from interface: IPipe

Retrieves and removes the last element from the pipe.

Returns:

the last element from the pipe, or null if the pipe is currently empty.

isEmpty

public boolean isEmpty()

Description copied from interface: IPipe

Checks whether the pipe is empty or not.

Returns:

true if the pipe is empty, false otherwise.

size

public int size()

Returns:

the current number of elements held by this pipe instance

capacity

public int capacity()

Returns:

the maximum number of elements possible to hold by this pipe instance