com.emphysic.myriad.network

Class PyramidActorPool

java.lang.Object

akka.actor.UntypedActor

com.emphysic.myriad.network.WorkerPool

com.emphysic.myriad.network.LinkedWorkerPool

com.emphysic.myriad.network.PyramidActorPool

All Implemented Interfaces:

akka.actor.Actor

public class PyramidActorPool
extends LinkedWorkerPool

PyramidActorPool - linked worker pool for performing Gaussian Pyramid 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
PyramidActorPool() Creates a new pool
PyramidActorPool(int numWorkers) Creates a new pool with the default Gaussian Pyramid operation
PyramidActorPool(int numWorkers, GaussianPyramidOperation gpo) Creates a new pool.

Method Summary

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

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

PyramidActorPool

public PyramidActorPool(int numWorkers,
                        GaussianPyramidOperation gpo)

Creates a new pool.

Parameters:

numWorkers - Number of workers in the pool

gpo - pyramid operation to perform

PyramidActorPool

public PyramidActorPool(int numWorkers)

Creates a new pool with the default Gaussian Pyramid operation

Parameters:

numWorkers - number of workers in the pool

PyramidActorPool

public PyramidActorPool()

Creates a new pool

Method Detail

onReceive

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

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

Specified by:

onReceive in class akka.actor.UntypedActor

Throws:

java.lang.Exception