Skip to content
Snippets Groups Projects
Commit a6dd37a7 authored by Christian Wulf's avatar Christian Wulf
Browse files

Merge branch 'added-javadoc' into 'master'

Added javadoc

See merge request !24
parents 3f8e9b07 39c08545
No related branches found
No related tags found
No related merge requests found
...@@ -30,8 +30,6 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -30,8 +30,6 @@ public class Analysis implements UncaughtExceptionHandler {
private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>(); private final Collection<Pair<Thread, Throwable>> exceptions = new ConcurrentLinkedQueue<Pair<Thread, Throwable>>();
private boolean initExecuted = false;
public Analysis(final AnalysisConfiguration configuration) { public Analysis(final AnalysisConfiguration configuration) {
this.configuration = configuration; this.configuration = configuration;
} }
...@@ -40,7 +38,6 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -40,7 +38,6 @@ public class Analysis implements UncaughtExceptionHandler {
* This initializes Analysis and needs to be run right before starting it. * This initializes Analysis and needs to be run right before starting it.
*/ */
public void init() { public void init() {
initExecuted = true;
final List<Stage> threadableStageJobs = this.configuration.getThreadableStageJobs(); final List<Stage> threadableStageJobs = this.configuration.getThreadableStageJobs();
for (Stage stage : threadableStageJobs) { for (Stage stage : threadableStageJobs) {
final Thread thread = new Thread(new RunnableStage(stage)); final Thread thread = new Thread(new RunnableStage(stage));
...@@ -67,9 +64,6 @@ public class Analysis implements UncaughtExceptionHandler { ...@@ -67,9 +64,6 @@ public class Analysis implements UncaughtExceptionHandler {
* @return a collection of thread/throwable pairs * @return a collection of thread/throwable pairs
*/ */
public Collection<Pair<Thread, Throwable>> start() { public Collection<Pair<Thread, Throwable>> start() {
if (!initExecuted) {
LOGGER.error("init() not executed before starting the analysis");
}
// start analysis // start analysis
startThreads(this.consumerThreads); startThreads(this.consumerThreads);
startThreads(this.finiteProducerThreads); startThreads(this.finiteProducerThreads);
......
/**
* Contains the implementation of the TeeTime framework.
*/
package teetime.framework;
\ No newline at end of file
/**
* Contains all pipes related classes, such as factories and pre-defined pipes.
*/
package teetime.framework.pipe;
\ No newline at end of file
/**
* Contains the signals that are used within the framework.
*/
package teetime.framework.signal;
\ No newline at end of file
/**
* Contains a set of pre-defined stages, which are ready-to-go and can be used for analysis configuration.
*/
package teetime.stage;
\ No newline at end of file
/**
* Contains a set of utility classes, which are used by the TeeTime framework.
*/
package teetime.util;
\ No newline at end of file
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment