Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Rice Pastry API
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

## 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

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

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| Rice Pastry API
PREV CLASS NEXT CLASS | FRAMES NO FRAMES
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD

Copyright © 2001-2005 - Rice Pastry.