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

Stage that executes an event handler with a thread pool More...

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

Public Member Functions
	ThreadPoolStage (IEventHandler< T > handler, int numThreads)
	Constructs a thread-pool stage More...
	ThreadPoolStage (IEventHandler< T > handler, ITaskService taskService)
	Constructs a thread-pool stage More...
override void	OnNext (T value)
	Handles the event using a thread in the thread pool More...
override void	Dispose ()
	Closes resources 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

Stage that executes an event handler with a thread pool

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.Impl.ThreadPoolStage< T >.ThreadPoolStage ( IEventHandler< T >  handler, int  numThreads  )

inline

Constructs a thread-pool stage

Parameters

handler	An event handler to execute
numThreads	The number of threads to use

Org.Apache.REEF.Wake.Impl.ThreadPoolStage< T >.ThreadPoolStage ( IEventHandler< T >  handler, ITaskService  taskService  )

inline

Constructs a thread-pool stage

Parameters

handler	an event handler to execute
taskService	an external executor service provided

Member Function Documentation

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

inlinevirtual

Closes resources

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

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

inlinevirtual

Handles the event using a thread in the thread pool

Parameters

value

an event

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/ThreadPoolStage.cs