Enforce intial value read

hereon-wpi · May 21, 2021 · 0526ba9 · 0526ba9
1 parent 7ca1d2f
commit 0526ba9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/main/java/wpn/hdri/ss/engine2/Engine.java b/src/main/java/wpn/hdri/ss/engine2/Engine.java
@@ -8,6 +8,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
@@ -49,9 +50,12 @@ public Engine(ScheduledExecutorService exec, DataStorage storage,
     private void start(boolean append, long delay){
         for(Attribute attr : polledAttributes){
             logger.debug("Scheduling polling task for {}", attr.fullName);
+            PollTask task = new PollTask(attr, storage, append);
             runningTasks.put(attr.fullName,
                     exec.scheduleWithFixedDelay(
-                            new PollTask(attr, storage, append), 0L, delay == -1 ? attr.delay : delay, TimeUnit.MILLISECONDS));
+                            task, 0L, delay == -1 ? attr.delay : delay, TimeUnit.MILLISECONDS));
+
+            CompletableFuture.runAsync(task);
         }
         for (Attribute attr : eventDrivenAttributes) {
             logger.debug("Subscribing to {}", attr.fullName);