org.opendaylight.openflowplugin.api.openflow.md.util

Class PollableQueuesZipper<T>

java.lang.Object

org.opendaylight.openflowplugin.api.openflow.md.util.PollableQueuesZipper<T>

Type Parameters:

T - common item type of zipped queues

public class PollableQueuesZipper<T>
extends Object

Zipper groups together a list of queues and exposes one poll method. Polling iterates through all groups and returns first not-null result of poll method on each queue. If after polling each grouped queue for one time there is still null result, poll will return null.
Iterating keeps last position so this polling is supposed to be fairly distributed.

Constructor Summary

Constructors

Constructor and Description
PollableQueuesZipper()

Method Summary

Modifier and Type	Method and Description
void	addSource(Queue<T> queue) Add all member queues before first invocation of poll().
T	poll() Next common product.

Methods inherited from class java.lang.Object

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

Constructor Detail

PollableQueuesZipper

public PollableQueuesZipper()

Method Detail

addSource

public void addSource(Queue<T> queue)

Add all member queues before first invocation of poll().

Parameters:

queue - to be added to group

poll

public T poll()

Next common product.

Returns:

next common product of polling member groups