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 if the queue is full, IllegalStateException is thrown

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

getInMeter, getOutMeter

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, 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