com.chemaxon.overlap.concurrent

Interface Processor

All Known Implementing Classes:

ProcessorImpl

public interface Processor

An abstraction of map-reduce. A function (process) is mapped to inputs from an iterator (source) and the results are reduced (target). Progress observing, error reporting also available.

Method Summary

Modifier and Type	Method and Description
<S,T> OptErrorH<S>	process(Iterator<S> source, Function<S,T> process, ResultHandler<S,T> target) Specify input, process and target.

Method Detail

process

<S,T> OptErrorH<S> process(Iterator<S> source,
                           Function<S,T> process,
                           ResultHandler<S,T> target)

Specify input, process and target. Without specifying error handle first error will be propagated. Without specifying total work underlying progress observer wont be switched to determinate mode.

This method blocks until completion. The callbacks are invoked only on the main thread. Any exception thrown in the callbacks will propagate.

Process function will possibly be invoked on multiple worker threads, it must be thread safe. Any exception will be recorded and reported later to the passed ErrorHandler.

Type Parameters:

S - Type of processed sources

T - Type of processed results

Parameters:

source - Source of inputs

process - Processing function

target - Results handler

Returns:

Possibility to specify error handler, total work and launch