com.chemaxon.overlap.concurrent

Class BatchedPagedProcessor

java.lang.Object

com.chemaxon.overlap.concurrent.BatchedPagedProcessor

public final class BatchedPagedProcessor
extends Object

Lightweight wrapper to provide batched paged processing.

Licensing: this class can be used with valid LicenseGlobals.MADFAST license.

Method Summary

Modifier and Type	Method and Description
static <S,T> long	process(int pagesize, int maxQueueSize, SubProgressObserver po, ExecutorService ex, Iterator<S> source, Function<S,T> process, ErrorHandler<S> error, ResultHandler<S,T> target) Launch a long running process.
static <S,T> long	processManaged(MBeanServer mbs, ObjectName on, int pagesize, int maxQueueSize, SubProgressObserver po, ListeningExecutorService ex, Iterator<S> source, Function<S,T> process, ErrorHandler<S> error, ResultHandler<S,T> target) Launch a managed long running process.

Methods inherited from class java.lang.Object

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

Method Detail

processManaged

public static <S,T> long processManaged(MBeanServer mbs,
                                        ObjectName on,
                                        int pagesize,
                                        int maxQueueSize,
                                        SubProgressObserver po,
                                        ListeningExecutorService ex,
                                        Iterator<S> source,
                                        Function<S,T> process,
                                        ErrorHandler<S> error,
                                        ResultHandler<S,T> target)
                                 throws InstanceAlreadyExistsException,
                                        MBeanRegistrationException,
                                        NotCompliantMBeanException

Launch a managed long running process.

This method blocks until done or cancelled through the supplied ProgressObserver. Note that management through JMX might use thread interruption for signalling

Type Parameters:

S - Source type

T - Target type

Parameters:

mbs - MBeanServer to provide instrumentation

on - ObjectName to pass to mbs

pagesize - Number of sources to bundle

maxQueueSize - Max queue size.

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

ex - ListeningExecutorService to use. Note that using MoreExecutors#sameThreadExecutor() results in sequentially consistent master thread execution. Use MoreExecutors.listeningDecorator(java.util.concurrent.ExecutorService) to acquire a ListeningExecutorService from an ExecutorService.

source - Inputs to process

process - Function to apply on each input

error - Handler for errors

target - Handler for results

Returns:

Sum of work units reported

Throws:

InstanceAlreadyExistsException - thrown

MBeanRegistrationException - thrown

NotCompliantMBeanException - thrown

LicenseException - when appropriate license is not available

process

public static <S,T> long process(int pagesize,
                                 int maxQueueSize,
                                 SubProgressObserver po,
                                 ExecutorService ex,
                                 Iterator<S> source,
                                 Function<S,T> process,
                                 ErrorHandler<S> error,
                                 ResultHandler<S,T> target)

Launch a long running process.

Type Parameters:

S - Source type

T - Target type

Parameters:

pagesize - Number of sources to bundle

maxQueueSize - Max queue size.

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

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

source - Inputs to process

process - Function to apply on each input

error - Handler for errors

target - Handler for results

Returns:

Total work units reported by ResultHandler.result(int, java.lang.Object, java.lang.Object)

Throws:

LicenseException - when appropriate license is not available