rice.environment.processing.sim
Class SimProcessor

java.lang.Object
  rice.environment.processing.sim.SimProcessor

All Implemented Interfaces:

Destructable, Processor

public class SimProcessor

extends java.lang.Object

implements Processor

Constructor Summary

SimProcessor(SelectorManager selector)

Method Summary

void	destroy() Shuts down the processing thread.
void	process(Executable task, Continuation command, SelectorManager selector, TimeSource ts, LogManager log) Schedules a job for processing on the dedicated processing thread.
void	processBlockingIO(WorkRequest request) Schedules a different type of task.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimProcessor

public SimProcessor(SelectorManager selector)

Method Detail

process

public void process(Executable task,
                    Continuation command,
                    SelectorManager selector,
                    TimeSource ts,
                    LogManager log)

Description copied from interface: Processor

Schedules a job for processing on the dedicated processing thread. CPU intensive jobs, such as encryption, erasure encoding, or bloom filter creation should never be done in the context of the underlying node's thread, and should only be done via this method. The continuation will be called on the Selector thread.

Specified by:

process in interface Processor

Parameters:

task - The task to run on the processing thread

command - The command to return the result to once it's done

processBlockingIO

public void processBlockingIO(WorkRequest request)

Description copied from interface: Processor

Schedules a different type of task. This thread is for doing Disk IO that is required to be blocking.

Specified by:

processBlockingIO in interface Processor

destroy

public void destroy()

Description copied from interface: Processor

Shuts down the processing thread.

Specified by:

destroy in interface Destructable

Specified by:

destroy in interface Processor