T
- the type of the Configuration
public 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.