Class ExecutionParallelism

java.lang.Object

com.knezevic.edaf.v3.core.runtime.ExecutionParallelism

public final class ExecutionParallelism
extends Object

Central runtime parallelism coordinator shared across run execution paths.

The framework executes two nested levels of work:

• run-level parallelism (multiple runs from batch/campaign)
• in-run fitness parallelism (candidate evaluation within one run)

This coordinator keeps global run activity count so in-run evaluators can dynamically scale their worker budget and avoid CPU oversubscription.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ExecutionParallelism.RunLease	AutoCloseable lease for active-run accounting.

Method Summary

Modifier and Type	Method	Description
static int	activeRuns()	Number of runs currently executing in this JVM process.
static int	availableProcessors()	Number of logical processors visible to the JVM.
static ExecutionParallelism.RunLease	enterRun()	Marks one run as active and returns lease that must be closed when run finishes.
static int	suggestedFitnessWorkersPerRun()	Dynamic worker budget for one run fitness evaluator.
static int	suggestedRunParallelism()	Recommended run-level concurrency for batch/campaign orchestration.

Methods inherited from class java.lang.Object

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

Method Details

availableProcessors

public static int availableProcessors()

Number of logical processors visible to the JVM.

suggestedRunParallelism

public static int suggestedRunParallelism()

Recommended run-level concurrency for batch/campaign orchestration.

activeRuns

public static int activeRuns()

Number of runs currently executing in this JVM process.

suggestedFitnessWorkersPerRun

public static int suggestedFitnessWorkersPerRun()

Dynamic worker budget for one run fitness evaluator.

When multiple runs are active, each run gets a proportional share of available CPUs.

enterRun

public static ExecutionParallelism.RunLease enterRun()

Marks one run as active and returns lease that must be closed when run finishes.