public interface IBascomConfig
DefaultBascomConfig
implementation is provided, which may be overridden and then set to replaced
whatever config is currently in place.BascomConfigFactory.setConfig(IBascomConfig)| Modifier and Type | Method and Description |
|---|---|
long |
getDefaultOrchestratorTimeoutMs()
Returns the default value for orchestrator timeout (when
Orchestrator.execute() is called). |
ITaskClosureGenerator |
getExecutionHook(Orchestrator orc,
String pass)
Returns a generator for use within an orchestration execution scope --
i.e.
|
ExecutorService |
getExecutor()
The pool from which threads are drawn as needed for parallel execution.
|
void |
notifyTerminate()
Called on shutdown (when it is possible to do so, typically in a
stand-alone program only).
|
void |
notifyThreadEnd(TaskThreadStat threadStat)
Called after a thread is has finished executing a task and there are no
other tasks ready to execute.
|
void |
notifyThreadStart(TaskThreadStat threadStat)
Called after a thread is pulled from the pool and before it starts
executing any task.
|
ExecutorService getExecutor()
long getDefaultOrchestratorTimeoutMs()
Orchestrator.execute() is called). Has
no effect when
Orchestrator.execute(long) is called, as
that method provides an explicit override of the default.for system default valuevoid notifyTerminate()
void notifyThreadStart(TaskThreadStat threadStat)
threadStat - metadata for threadvoid notifyThreadEnd(TaskThreadStat threadStat)
threadStat - metadata for threadITaskClosureGenerator getExecutionHook(Orchestrator orc, String pass)
Orchestrator.execute(long, String).
Subclasses can provide their own version instead of the default which
generates TaskMethodClosure instances directly. The returned
value can be a singleton or created for each call if the subclass needs
to keep its own state.orc - on which the execution was invokedpass - provided as param to
Orchestrator.execute(long, String)Copyright © 2018. All rights reserved.