org.apache.reef.wake.impl

Class SingleThreadStage<T>

java.lang.Object

org.apache.reef.wake.AbstractEStage<T>

org.apache.reef.wake.impl.SingleThreadStage<T>

Type Parameters:

T - type

All Implemented Interfaces:

AutoCloseable, EStage<T>, EventHandler<T>, Stage

public final class SingleThreadStage<T>
extends AbstractEStage<T>

Single thread stage that runs the event handler.

Constructor Summary

Constructors

Constructor and Description
SingleThreadStage(EventHandler<T> handler, int capacity) Constructs a single thread stage.
SingleThreadStage(String name, EventHandler<T> handler, int capacity) Constructs a single thread stage.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the stage.
void	onNext(T value) Puts the value to the queue, which will be processed by the handler later.

Methods inherited from class org.apache.reef.wake.AbstractEStage

getInMeter, getOutMeter, isClosed, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SingleThreadStage

@Inject
public SingleThreadStage(EventHandler<T> handler,
                        int capacity)

Constructs a single thread stage.

Parameters:

handler - the event handler to execute

capacity - the queue capacity

SingleThreadStage

@Inject
public SingleThreadStage(String name,
                        EventHandler<T> handler,
                        int capacity)

Constructs a single thread stage.

Parameters:

name - the stage name

handler - the event handler to execute

capacity - the queue capacity

Method Detail

onNext

public void onNext(T value)

Puts the value to the queue, which will be processed by the handler later. if the queue is full, IllegalStateException is thrown

Parameters:

value - the value

Throws:

IllegalStateException

close

public void close()
           throws Exception

Closes the stage.

Throws:

Exception