teetime.framework.pipe

Interface IMonitorablePipe

All Known Implementing Classes:

BoundedSynchedPipe

public interface IMonitorablePipe

Method Summary

Modifier and Type	Method and Description
int	capacity()
long	getNumPullsSinceAppStart()
long	getNumPushesSinceAppStart()
int	getNumWaits()
long	getPullThroughput()
long	getPushThroughput()
int	size()

Method Detail

size

int size()

capacity

int capacity()

getNumPushesSinceAppStart

long getNumPushesSinceAppStart()

Returns:

the number of pushes to this queue since application start

getNumPullsSinceAppStart

long getNumPullsSinceAppStart()

Returns:

the number of pulls from this queue since application start

getPushThroughput

long getPushThroughput()

Returns:

the number of pushes to this queue since last method call

getPullThroughput

long getPullThroughput()

Returns:

the number of pulls to this queue since last method call

getNumWaits

int getNumWaits()

Returns:

the number of pauses of the pushing stage