com.emphysic.myriad.network

Class DatasetOperationPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

com.emphysic.myriad.network.DatasetOperationPool

All Implemented Interfaces:

akka.actor.Actor

public class DatasetOperationPool
extends LinkedWorkerPool

DatasetOperationPool - linked worker pool for performing operations on Datasets.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Field Summary

Fields inherited from class com.emphysic.myriad.network.LinkedWorkerPool

next

Fields inherited from class com.emphysic.myriad.network.WorkerPool

DEFAULTWORKERS, router

Constructor Summary

Constructors

Constructor and Description
DatasetOperationPool(DatasetOperation op) Starts a new pool to perform the specified operation.
DatasetOperationPool(int workers, DatasetOperation op) Creates a new pool with the specified number of workers.
DatasetOperationPool(akka.routing.Pool pool, DatasetOperation op) Creates a new pool from an existing one

Method Summary

Modifier and Type	Method and Description
void	onReceive(java.lang.Object message) Handled Messages DatasetMessage - if received from worker pool, sent to the next link.

Methods inherited from class com.emphysic.myriad.network.LinkedWorkerPool

getNext, getNextActor, setNext, shutdown, tellNextActor, tellNextActor

Methods inherited from class com.emphysic.myriad.network.WorkerPool

genMessage, getRouter, setRouter, start, start, start, tellRouter, tellRouter

Methods inherited from class akka.actor.UntypedActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, getContext, getSelf, getSender, postRestart, postStop, preRestart, preStart, receive, self, sender, supervisorStrategy, unhandled

Methods inherited from class java.lang.Object

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

Constructor Detail

DatasetOperationPool

public DatasetOperationPool(int workers,
                            DatasetOperation op)

Creates a new pool with the specified number of workers.

Parameters:

workers - number of workers

op - operation each worker performs on a received Dataset

DatasetOperationPool

public DatasetOperationPool(akka.routing.Pool pool,
                            DatasetOperation op)

Creates a new pool from an existing one

Parameters:

pool - pool

op - operation to perform

DatasetOperationPool

public DatasetOperationPool(DatasetOperation op)

Starts a new pool to perform the specified operation.

Parameters:

op - operation to perform

Method Detail

onReceive

public void onReceive(java.lang.Object message)
               throws java.lang.Exception

Handled Messages DatasetMessage - if received from worker pool, sent to the next link. Otherwise sent to the worker pool for processing. ActorRef - sets the next link. ShutdownMessage - initiates shutdown

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception