teetime.stage.basic.merger.strategy

Class NonBlockingFiniteRoundRobinStrategy

java.lang.Object

teetime.stage.basic.merger.strategy.NonBlockingFiniteRoundRobinStrategy

All Implemented Interfaces:

IMergerStrategy, PortRemovedListener<InputPort<?>>

public class NonBlockingFiniteRoundRobinStrategy
extends Object
implements IMergerStrategy

Represents a strategy for the Merger stage. This strategy returns a non-null element from the next non-empty input port. If an input port is empty, its successor input port is checked. If the successor input port is also empty, the successor's successor input port is checked and so on. Hereby, each input port is checked at most once. This strategy continues with the successor of the input port used in the previous run.

Since:

3.0

Author:

Nils Christian Ehmke, Christian Wulf

Constructor Summary

Constructors

Constructor and Description
NonBlockingFiniteRoundRobinStrategy()

Method Summary

Modifier and Type	Method and Description
<T> T	getNextInput(Merger<T> merger)
void	onPortRemoved(InputPort<?> removedInputPort)

Methods inherited from class java.lang.Object

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

Constructor Detail

NonBlockingFiniteRoundRobinStrategy

public NonBlockingFiniteRoundRobinStrategy()

Method Detail

getNextInput

public <T> T getNextInput(Merger<T> merger)

Specified by:

getNextInput in interface IMergerStrategy

onPortRemoved

public void onPortRemoved(InputPort<?> removedInputPort)

Specified by:

onPortRemoved in interface PortRemovedListener<InputPort<?>>