org.apache.reef.wake.examples.p2p

Class Pull2Push<T>

java.lang.Object

org.apache.reef.wake.examples.p2p.Pull2Push<T>

Type Parameters:

T - the message type

All Implemented Interfaces:

AutoCloseable, Runnable

public final class Pull2Push<T>
extends Object
implements Runnable, AutoCloseable

Performs a Pull-to-Push conversion in Wake.

The class pulls from a set of event sources, and pushes to a single EventHandler. If the downstream event handler blocks, this will block, providing a simple rate limiting scheme.

The EventSources are managed in a basic Queue.

Constructor Summary

Constructors

Constructor and Description
Pull2Push(EventHandler<T> output)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	register(EventSource<T> source) Registers an event source.
void	run() Executes the message loop.

Methods inherited from class java.lang.Object

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

Constructor Detail

Pull2Push

public Pull2Push(EventHandler<T> output)

Parameters:

output - the EventHandler that receives the messages from this Pull2Push.

Method Detail

register

public final void register(EventSource<T> source)

Registers an event source.

Parameters:

source - The source that will be added to the queue of this Pull2Push

run

public void run()

Executes the message loop.

Specified by:

run in interface Runnable

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception