chemaxon.util.concurrent.processors
Class ConcurrentProcessors

java.lang.Object
  chemaxon.util.concurrent.processors.ConcurrentProcessors

public final class ConcurrentProcessors
extends java.lang.Object

Creates ConcurrentProcessor instances.

Author:

pkovacs

Field Summary

static int	IN_INPUT_ORDER
static int	SINGLE_THREADED
static int	UNORDERED

Method Summary

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 java.lang.Exception

For test only

Parameters:

resultOrder -

workUnitInputProducer -

workUnitFactory -

Returns:

Throws:

java.lang.Exception