com.chemaxon.overlap.concurrent.impl

Class ProcessorImpl

java.lang.Object

com.chemaxon.overlap.concurrent.impl.ProcessorImpl

All Implemented Interfaces:

Processor

public class ProcessorImpl
extends Object
implements Processor

Implementation of Processor map-reduce abstraction.

Constructor Summary

Constructors

Constructor and Description
ProcessorImpl(BppParameters params) Construct.

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessorImpl

public ProcessorImpl(BppParameters params)

Construct.

Parameters:

params - Parameters

Method Detail

process

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

Description copied from interface: Processor

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.

Specified by:

process in interface Processor

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