com.chemaxon.overlap.concurrent

Class Processors

java.lang.Object

com.chemaxon.overlap.concurrent.Processors

public final class Processors
extends Object

Utility class for Processor based map-reduce reactors. To use these functionalities license LicenseGlobals.MADFAST must be present.

Method Summary

Modifier and Type	Method and Description
static Processor	managedProcessor(String objectName, int pagesize, int maxQueueSize, SubProgressObserver po, ExecutorService ex) Create a managed processor.
static Processor	processor(BppParameters params) Create a processor with a parameters object.
static Processor	processor(int pagesize, int maxQueueSize, SubProgressObserver po, ExecutorService ex) Create an unmanaged processor.

Methods inherited from class java.lang.Object

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

Method Detail

processor

public static Processor processor(int pagesize,
                                  int maxQueueSize,
                                  SubProgressObserver po,
                                  ExecutorService ex)

Create an unmanaged processor.

Parameters:

pagesize - Number of sources to bundle

maxQueueSize - Max queue size.

po - Progress observer to track execution. Method ProgressObserver.done() will be invoked before encapsulated execution returns

ex - ExecutorService to use. Note that using MoreExecutors#sameThreadExecutor() results in sequentially consistent master thread execution

Returns:

Processor reference

managedProcessor

public static Processor managedProcessor(String objectName,
                                         int pagesize,
                                         int maxQueueSize,
                                         SubProgressObserver po,
                                         ExecutorService ex)

Create a managed processor.

Parameters:

objectName - Object name for management

pagesize - Number of sources to bundle

maxQueueSize - Max queue size.

po - Progress observer to track execution. Method ProgressObserver.done() will be invoked before encapsulated execution returns

ex - ExecutorService to use. Note that using MoreExecutors#sameThreadExecutor() results in sequentially consistent master thread execution

Returns:

Processor reference

processor

public static Processor processor(BppParameters params)

Create a processor with a parameters object.

Parameters:

params - Parameters object

Returns:

Processor reference