Package bbflow

Class ff_queue_TCP<T>

java.lang.Object

bbflow.ff_queue<T>

bbflow.ff_queue_TCP<T>

Type Parameters:

T - Type of channels of the queue

public class ff_queue_TCP<T>
extends ff_queue<T>

Queue extending ff_queue exploting a network channel. The channel is uni-directional and type of it must be specified during initialization (INPUT/OUTPUT)

Field Summary

Fields

Modifier and Type	Field	Description
(package private) objectClient	client
int	connectionId
static final int	INPUT
static final int	OUTPUT
(package private) Thread	server
(package private) int	sockettype

Fields inherited from class bbflow.ff_queue

blocking, blocking_queue, bounded, EOS, nonblocking_bounded_queue, nonblocking_queue

Constructor Summary

Constructors

Constructor	Description
ff_queue_TCP(int type, int connectionId)
ff_queue_TCP(int type, int connectionId, String host)

Method Summary

Modifier and Type	Method	Description
boolean	offer(T i)	Inserts the specified element at the tail of this queue if it is possible to do so immediately without exceeding the queue's capacity, returning true upon success and false if this queue is full
boolean	offer(T i, long timeout, TimeUnit timeunit)	Inserts the specified element at the tail of this queue, waiting if necessary up to the specified wait time for space to become available.
void	put(T i)	Inserts the specified element at the tail of this queue, waiting if necessary for space to become available (if bounded)
void	setEOS()	tell the Queue the end of stream reached

Methods inherited from class bbflow.ff_queue

getEOS, poll, poll, preload, size, sleepNanos, take

Methods inherited from class java.lang.Object

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

Field Details

client

objectClient client

server

Thread server

INPUT

public static final int INPUT

See Also:

• Constant Field Values

OUTPUT

public static final int OUTPUT

See Also:

• Constant Field Values

sockettype

int sockettype

connectionId

public int connectionId

Constructor Details

ff_queue_TCP

public ff_queue_TCP(int type,
 int connectionId,
 String host)

ff_queue_TCP

public ff_queue_TCP(int type,
 int connectionId)

Method Details

put

public void put(T i)

Description copied from class: ff_queue

Inserts the specified element at the tail of this queue, waiting if necessary for space to become available (if bounded)

Overrides:

put in class ff_queue<T>

Parameters:

i - Element to insert

setEOS

public void setEOS()

tell the Queue the end of stream reached

Overrides:

setEOS in class ff_queue<T>

offer

public boolean offer(T i,
 long timeout,
 TimeUnit timeunit)
              throws InterruptedException

Description copied from class: ff_queue

Inserts the specified element at the tail of this queue, waiting if necessary up to the specified wait time for space to become available.

Overrides:

offer in class ff_queue<T>

Parameters:

i - element to insert

timeout - time to wait

timeunit - unit of the time to wait

Returns:

true or false

Throws:

InterruptedException

offer

public boolean offer(T i)

Description copied from class: ff_queue

Inserts the specified element at the tail of this queue if it is possible to do so immediately without exceeding the queue's capacity, returning true upon success and false if this queue is full

Overrides:

offer in class ff_queue<T>

Parameters:

i - element to insert

Returns:

true or false