1 files changed, 23 insertions, 1 deletions
diff --git a/src/main/java/io/trygvis/Main.java b/src/main/java/io/trygvis/Main.java
index 448c3e4..0a31aaa 100755
--- a/src/main/java/io/trygvis/Main.java
+++ b/src/main/java/io/trygvis/Main.java
@@ -11,6 +11,7 @@ import org.springframework.stereotype.*;
 import java.util.*;
 
 import static java.lang.System.*;
+import static java.lang.Thread.*;
 
 @Component
 public class Main {
@@ -34,7 +35,7 @@ public class Main {
         try {
             context.getBean(Main.class).run();
             log.info("Sleeping");
-            Thread.sleep(1000 * 1000);
+            sleep(1000 * 1000);
         } catch (Exception e) {
             e.printStackTrace(System.out);
         }
@@ -71,5 +72,26 @@ public class Main {
         for (int i = 0; i < 10; i++) {
             refs.add(asyncService.schedule(queue));
         }
+
+        while (true) {
+            log.info("size = {}", refs.size());
+            for (Iterator<AsyncService.ExecutionRef> iterator = refs.iterator(); iterator.hasNext(); ) {
+                AsyncService.ExecutionRef ref = iterator.next();
+
+                ref = asyncService.update(ref);
+
+                log.info("ref = {}", ref);
+
+                if (ref.isDone()) {
+                    iterator.remove();
+                }
+
+                sleep(100);
+            }
+
+            if (refs.isEmpty()) {
+                break;
+            }
+        }
     }
 }