Rice Pastry API

rice.environment.processing.simple
Class SimpleProcessor

java.lang.Object
  extended by rice.environment.processing.simple.SimpleProcessor
All Implemented Interfaces:
Destructable, Processor

public class SimpleProcessor
extends java.lang.Object
implements Processor

Author:
Jeff Hoye

Constructor Summary
SimpleProcessor(java.lang.String name)
           
 
Method Summary
 void destroy()
          Shuts down the processing thread.
 WorkQueue getIOQueue()
           
 ProcessingQueue getQueue()
           
 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 workRequest)
          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

SimpleProcessor

public SimpleProcessor(java.lang.String name)
Method Detail

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 thread
command - 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()

Rice Pastry API

Copyright © 2001-2005 - Rice Pastry.


Imprint-Dataprotection