chemaxon.util.concurrent.processors

Class ConcurrentProcessors

java.lang.Object

chemaxon.util.concurrent.processors.ConcurrentProcessors

public final class ConcurrentProcessors
extends Object

Creates ConcurrentProcessor instances.

Author:

pkovacs

Field Summary

Fields

Modifier and Type	Field and Description
static int	IN_INPUT_ORDER
static int	SINGLE_THREADED
static int	UNORDERED

Method Summary

Methods

Modifier and Type	Method and Description
static ConcurrentProcessor	create(int resultOrder, InputProducer callableProducer)
static ConcurrentProcessor	create(int processorType, InputProducer workUnitInputProducer, WorkUnitFactory workUnitFactory)
static ConcurrentProcessor	createPooledWu(int resultOrder, InputProducer workUnitInputProducer, WorkUnitFactory workUnitFactory) For test only

Methods inherited from class java.lang.Object

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

Field Detail

UNORDERED

public static final int UNORDERED

See Also:

Constant Field Values

IN_INPUT_ORDER

public static final int IN_INPUT_ORDER

See Also:

Constant Field Values

SINGLE_THREADED

public static final int SINGLE_THREADED

See Also:

Constant Field Values

Method Detail

create

public static final ConcurrentProcessor create(int resultOrder,
                         InputProducer callableProducer)

create

public static final ConcurrentProcessor create(int processorType,
                         InputProducer workUnitInputProducer,
                         WorkUnitFactory workUnitFactory)

createPooledWu

public static final ConcurrentProcessor createPooledWu(int resultOrder,
                                 InputProducer workUnitInputProducer,
                                 WorkUnitFactory workUnitFactory)
                                                throws Exception

For test only

Parameters:

resultOrder -

workUnitInputProducer -

workUnitFactory -

Returns:

the requested ConcurrentProcessor implementation

Throws:

Exception