T - the type of the Configurationpublic final class Execution<T extends Configuration> extends Object
Configuration,
in which the adding and configuring of stages takes place.
To start the analysis executeBlocking() needs to be executed.
This class will automatically create threads and join them without any further commitment.| Constructor and Description |
|---|
Execution(T configuration)
Creates a new
Execution. |
Execution(T configuration,
boolean validationEnabled)
Uses
PushPullScheduling as default scheduler. |
Execution(T configuration,
boolean validationEnabled,
TeeTimeScheduler scheduler) |
| Modifier and Type | Method and Description |
|---|---|
void |
abortEventually()
Terminates all producer stages, interrupts all threads, and waits for a graceful termination.
|
void |
executeBlocking()
This method will start this execution and block until it is finished.
|
Future<Void> |
executeNonBlocking()
This method starts this execution without waiting for its termination.
|
T |
getConfiguration()
Retrieves the Configuration which was used to add and arrange all stages needed for this execution.
|
static void |
main(String... args) |
void |
waitForTermination()
Calling this method will block the current thread until the execution terminates.
|
public Execution(T configuration)
Execution. It validates the given configuration and uses the PushPullScheduling as default scheduler.configuration - to be executedpublic Execution(T configuration, boolean validationEnabled)
PushPullScheduling as default scheduler.configuration - to be executed.validationEnabled - true if validation should be performed after initialization; false otherwise.public Execution(T configuration, boolean validationEnabled, TeeTimeScheduler scheduler)
configuration - to be executed.validationEnabled - true if validation should be performed after initialization; false otherwise.scheduler - to be used for the given configuration.public void waitForTermination()
ExecutionException - if at least one exception in one thread has occurred within the execution. The exception contains the pairs of thread and throwablepublic void abortEventually()
public Future<Void> executeNonBlocking()
waitForTermination() must be called to unsure a correct termination
of the execution.public void executeBlocking()
ExecutionException - if at least one exception in one thread has occurred within the execution. The exception contains the pairs of thread and throwable.public T getConfiguration()
public static void main(String... args)
Copyright © 2015–2020. All rights reserved.