rice.environment.processing.simple
Class SimpleProcessor
java.lang.Object
rice.environment.processing.simple.SimpleProcessor
- All Implemented Interfaces:
- Destructable, Processor
public class SimpleProcessor
- extends java.lang.Object
- implements Processor
- Author:
- Jeff Hoye
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SimpleProcessor
public SimpleProcessor(java.lang.String name)
process
public void process(Executable task,
Continuation command,
SelectorManager selector,
TimeSource ts,
LogManager log)
- 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.
- Specified by:
process
in interface Processor
- Parameters:
task
- The task to run on the processing threadcommand
- The command to return the result to once it's done
processBlockingIO
public void processBlockingIO(WorkRequest workRequest)
- 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
getQueue
public ProcessingQueue getQueue()
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
getIOQueue
public WorkQueue getIOQueue()
Copyright © 2001-2005 - Rice Pastry.