org.optaplanner.core.config.partitionedsearch

Class PartitionedSearchPhaseConfig

java.lang.Object

org.optaplanner.core.config.AbstractConfig<C>

org.optaplanner.core.config.phase.PhaseConfig<PartitionedSearchPhaseConfig>

org.optaplanner.core.config.partitionedsearch.PartitionedSearchPhaseConfig

public class PartitionedSearchPhaseConfig
extends PhaseConfig<PartitionedSearchPhaseConfig>

Field Summary

Fields

Modifier and Type	Field and Description
static String	ACTIVE_THREAD_COUNT_AUTO
static String	ACTIVE_THREAD_COUNT_UNLIMITED
protected List<PhaseConfig>	phaseConfigList
protected String	runnablePartThreadLimit
protected Class<? extends ThreadFactory>	threadFactoryClass

Constructor Summary

Constructors

Constructor and Description
PartitionedSearchPhaseConfig()

Method Summary

Modifier and Type	Method and Description
PartitionedSearchPhase	buildPhase(int phaseIndex, HeuristicConfigPolicy solverConfigPolicy, BestSolutionRecaller bestSolutionRecaller, Termination solverTermination)
List<PhaseConfig>	getPhaseConfigList()
String	getRunnablePartThreadLimit() Similar to a thread pool size, but instead of limiting the number of Threads, it limits the number of Thread.State#RUNNABLE Threads to avoid consuming all CPU resources (which would starve UI, Servlets and REST threads).
Class<SolutionPartitioner>	getSolutionPartitionerClass()
Class<? extends ThreadFactory>	getThreadFactoryClass()
void	inherit(PartitionedSearchPhaseConfig inheritedConfig) Inherits each property of the inheritedConfig unless that property (or a semantic alternative) is defined by this instance (which overwrites the inherited behaviour).
void	setPhaseConfigList(List<PhaseConfig> phaseConfigList)
void	setRunnablePartThreadLimit(String runnablePartThreadLimit)
void	setSolutionPartitionerClass(Class<SolutionPartitioner> solutionPartitionerClass)
void	setThreadFactoryClass(Class<? extends ThreadFactory> threadFactoryClass)

Methods inherited from class org.optaplanner.core.config.phase.PhaseConfig

buildPhaseTermination, getTerminationConfig, setTerminationConfig, toString

Methods inherited from class org.optaplanner.core.config.AbstractConfig

deduceEntityDescriptor, deduceVariableDescriptor, deduceVariableDescriptorList, newInstance

Methods inherited from class java.lang.Object

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

Field Detail

ACTIVE_THREAD_COUNT_AUTO

public static final String ACTIVE_THREAD_COUNT_AUTO

See Also:

Constant Field Values

ACTIVE_THREAD_COUNT_UNLIMITED

public static final String ACTIVE_THREAD_COUNT_UNLIMITED

See Also:

Constant Field Values

threadFactoryClass

protected Class<? extends ThreadFactory> threadFactoryClass

runnablePartThreadLimit

protected String runnablePartThreadLimit

phaseConfigList

protected List<PhaseConfig> phaseConfigList

Constructor Detail

PartitionedSearchPhaseConfig

public PartitionedSearchPhaseConfig()

Method Detail

getThreadFactoryClass

public Class<? extends ThreadFactory> getThreadFactoryClass()

setThreadFactoryClass

public void setThreadFactoryClass(Class<? extends ThreadFactory> threadFactoryClass)

getRunnablePartThreadLimit

public String getRunnablePartThreadLimit()

Similar to a thread pool size, but instead of limiting the number of Threads, it limits the number of Thread.State#RUNNABLE Threads to avoid consuming all CPU resources (which would starve UI, Servlets and REST threads).

The number of Threads is always equal to the number of partitions returned by SolutionPartitioner.splitWorkingSolution(ScoreDirector), because otherwise some partitions would never run (especially with asynchronous termination). If this limit (or Runtime#availableProcessors()) is lower than the number of partitions, this results in a slower score calculation speed per partition {@link Solver}.

Defaults to {@value #ACTIVE_THREAD_COUNT_AUTO} which consumes the majority but not all of the CPU cores on multi-core machines, preventing other processes (including your IDE or SSH connection) on the machine from hanging.

Use {@value #ACTIVE_THREAD_COUNT_UNLIMITED} to give it all CPU cores. This is usefull if you're handling the CPU consumption on an OS level.

Returns:

null, a number, "AUTO", "UNLIMITED" or a JavaScript calculation using .

setRunnablePartThreadLimit

public void setRunnablePartThreadLimit(String runnablePartThreadLimit)

getSolutionPartitionerClass

public Class<SolutionPartitioner> getSolutionPartitionerClass()

setSolutionPartitionerClass

public void setSolutionPartitionerClass(Class<SolutionPartitioner> solutionPartitionerClass)

getPhaseConfigList

public List<PhaseConfig> getPhaseConfigList()

setPhaseConfigList

public void setPhaseConfigList(List<PhaseConfig> phaseConfigList)

buildPhase

public PartitionedSearchPhase buildPhase(int phaseIndex,
                                         HeuristicConfigPolicy solverConfigPolicy,
                                         BestSolutionRecaller bestSolutionRecaller,
                                         Termination solverTermination)

Specified by:

buildPhase in class PhaseConfig<PartitionedSearchPhaseConfig>

inherit

public void inherit(PartitionedSearchPhaseConfig inheritedConfig)

Description copied from class: AbstractConfig

Inherits each property of the inheritedConfig unless that property (or a semantic alternative) is defined by this instance (which overwrites the inherited behaviour).

After the inheritance, if a property on this AbstractConfig composition is replaced, it should not affect the inherited composition instance.

Overrides:

inherit in class PhaseConfig<PartitionedSearchPhaseConfig>

Parameters:

inheritedConfig - never null