com.ebay.bascomtask.core

Class GlobalOrchestratorConfig

java.lang.Object

com.ebay.bascomtask.core.GlobalOrchestratorConfig

public class GlobalOrchestratorConfig
extends Object

Maintains configuration settings that will be applied to new Orchestrators.

Author:

Brendan McCarthy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GlobalOrchestratorConfig.Config Default implementation maintains values that are transferred to an Orchestrator on demand.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_FIXED_THREADPOOL_SIZE

Constructor Summary

Constructors

Constructor and Description
GlobalOrchestratorConfig()

Method Summary

Modifier and Type	Method and Description
static GlobalOrchestratorConfig.Config	getConfig()
static <T extends TaskRunner> LaneRunner<T>	interceptFirstOnCreate(Supplier<T> createFn) Set a TaskRunner creation function that will apply to every Orchestrator created in this this thread.
static <T extends TaskRunner> LaneRunner<T>	interceptLastOnCreate(Supplier<T> createFn) Set a TaskRunner creation function that will apply to every Orchestrator created in this this thread.
static void	setConfig(GlobalOrchestratorConfig.Config config)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_FIXED_THREADPOOL_SIZE

public static final int DEFAULT_FIXED_THREADPOOL_SIZE

See Also:

Constant Field Values

Constructor Detail

GlobalOrchestratorConfig

public GlobalOrchestratorConfig()

Method Detail

getConfig

public static GlobalOrchestratorConfig.Config getConfig()

setConfig

public static void setConfig(GlobalOrchestratorConfig.Config config)

interceptFirstOnCreate

public static <T extends TaskRunner> LaneRunner<T> interceptFirstOnCreate(Supplier<T> createFn)

Set a TaskRunner creation function that will apply to every Orchestrator created in this this thread. Each newly-created TaskRunner will be added first in the taskRunner chain.

The mechanism uses ThreadLocal internally and those must be closed properly to ensure cleanup of threadLocal state. A typical usage is thus:

   try (LaneRunner<MyTaskRunner> laneRunner = GlobalOrchestratorConfig.interceptFirstOnCreate(MyTaskRunner::new)) {
       // Perform any logic here that might create Orchestrators at any point
       laneRunner.runners.forEach(r->performRunnerOperation(r));
   }
 

Multiple TaskRunners can be installed in this way by nesting these calls.

Type Parameters:

T - class of any TaskRunners that will be created

Parameters:

createFn - to create a TaskRunner instance of the desired type

Returns:

a LaneRunner whose 'futures' member variable provides access to any TaskRunners actually created

interceptLastOnCreate

public static <T extends TaskRunner> LaneRunner<T> interceptLastOnCreate(Supplier<T> createFn)

Set a TaskRunner creation function that will apply to every Orchestrator created in this this thread. Each newly-created TaskRunner will be added first in the taskRunner chain.

See other considerations as described in interceptFirstOnCreate(Supplier).

Type Parameters:

T - class of any TaskRunners that will be created

Parameters:

createFn - to create a TaskRunner instance of the desired type

Returns:

a LaneRunner whose 'futures' member variable provides access to any TaskRunners actually created