+ return thread == null ? new IThread[0] : new IThread[] { thread };
+ }
+
+ public void addExecutionSpeedListener(Consumer<Double> executionSpeedListener)
+ {
+ executionSpeedListeners.add(executionSpeedListener);
+ }
+
+ public void removeExecutionSpeedListener(Consumer<Double> executionSpeedListener)
+ {
+ executionSpeedListeners.remove(executionSpeedListener);
+ }
+
+ private void callExecutionSpeedListener(double executionSpeed)
+ {
+ executionSpeedListeners.forEach(l -> l.accept(executionSpeed));