diff --git a/src/main/java/teetime/framework/Analysis.java b/src/main/java/teetime/framework/Analysis.java index 711c5c90b1b925556b4a77caf0bf2c875c20ecbd..9579e00d6dc7837925f8e01c5529f1218899dc1e 100644 --- a/src/main/java/teetime/framework/Analysis.java +++ b/src/main/java/teetime/framework/Analysis.java @@ -256,19 +256,20 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught } } - // public void abortEventually() { - // for (Thread thread : this.finiteProducerThreads) { - // thread.interrupt(); - // } - // - // for (Thread thread : this.consumerThreads) { - // thread.interrupt(); - // } - // - // for (Thread thread : this.infiniteProducerThreads) { - // thread.interrupt(); - // } - // } + // TODO: implement + private void abortEventually() { + for (Thread thread : this.finiteProducerThreads) { + thread.interrupt(); + } + + for (Thread thread : this.consumerThreads) { + thread.interrupt(); + } + + for (Thread thread : this.infiniteProducerThreads) { + thread.interrupt(); + } + } /** * This method will start the Analysis and block until it is finished.