Concurrent Conduit

This concurrent conduit uses fork/join mechanisms to distribute sample evaluation among n concurrent workers, each running as separate process from the main application process. Communication among workers is realized via OS pipes.

Use this model if your application cannot be parallelized with MPI or linked to Korali in any way.

For example, pre-packaged (black-box) applications can be run using this conduit and then instantiating a new process per sample evaluation (see: Concurrent Execution Example).

For more information, see Parallel Execution.

Usage

k["Conduit"]["Type"] = "Concurrent"

Configuration

These are settings required by this module.

Concurrent Jobs

• Usage: e[“Conduit”][“Concurrent Jobs”] = unsigned integer

• Description: Specifies the number of worker processes (jobs) running concurrently.

Default Configuration

These following configuration will be assigned by default. Any settings defined by the user will override the given settings specified in these defaults.

{
"Concurrent Jobs": 1
}