Org.Apache.REEF.Wake.Impl.SingleThreadStage< T > Class Template Reference

Single thread stage that runs the event handler More...

Inherits Org.Apache.REEF.Wake.AbstractEStage< T >.

Public Member Functions
	SingleThreadStage (IEventHandler< T > handler, int capacity)
override 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 More...
override void	Dispose ()
	Closes the stage More...

Additional Inherited Members
Protected Member Functions inherited from Org.Apache.REEF.Wake.AbstractEStage< T >
	AbstractEStage (string meterName)
	Constructs an abstract estage More...

Detailed Description

Single thread stage that runs the event handler

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Impl.SingleThreadStage< T >.SingleThreadStage ( IEventHandler< T >  handler, int  capacity  )

inline

Member Function Documentation

override void Org.Apache.REEF.Wake.Impl.SingleThreadStage< T >.Dispose ( )

inlinevirtual

Closes the stage

Implements Org.Apache.REEF.Wake.AbstractEStage< T >.

override void Org.Apache.REEF.Wake.Impl.SingleThreadStage< T >.OnNext ( T  value )

inlinevirtual

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

Reimplemented from Org.Apache.REEF.Wake.AbstractEStage< T >.

---

The documentation for this class was generated from the following file:

• lang/cs/Org.Apache.REEF.Wake/Impl/SingleThreadStage.cs