Added test for scheduler queueing

Author: i-make-robots

pom.xml

@@ -4,7 +4,7 @@
 
     <groupId>com.marginallyclever</groupId>
     <artifactId>nodegraphcore</artifactId>
-    <version>1.6.0</version>
+    <version>1.6.1</version>
 
     <name>NodeGraphCore</name>
     <description>Flow based programming in Java.</description>

src/test/java/com/marginallyclever/nodegraphcore/TestGraph.java

@@ -78,12 +78,27 @@ private void buildAddTwoConstants() {
     public void testAddTwoConstants() {
         buildAddTwoConstants();
         ThreadPoolScheduler scheduler = new ThreadPoolScheduler();
+        scheduler.setQueueDownstreamNodes(true);
         scheduler.submit(graph.getNodes().get(0));
         scheduler.submit(graph.getNodes().get(1));
         scheduler.run();
         assertEquals( 3.0, graph.getNodes().get(2).getPort(2).getValue() );
     }
 
+    /**
+     * confirm adding two constants together via {@link Connection}s works as expected
+     */
+    @Test
+    public void testAddTwoConstantsFailsWithoutScheduler() {
+        buildAddTwoConstants();
+        ThreadPoolScheduler scheduler = new ThreadPoolScheduler();
+        scheduler.setQueueDownstreamNodes(false);
+        scheduler.submit(graph.getNodes().get(0));
+        scheduler.submit(graph.getNodes().get(1));
+        scheduler.run();
+        assertNotEquals( 3.0, graph.getNodes().get(2).getPort(2).getValue() );
+    }
+
     /**
      * confirm adding two constants together via {@link Connection}s works as expected.
      * confirm {@link PrintToStdOut} works as expected.
@@ -95,6 +110,7 @@ public void testAddTwoConstantsAndReport() {
         Node report = graph.add(new PrintToStdOut());
         graph.add(new Connection(graph.getNodes().get(2),2,report,0));
 
+        scheduler.setQueueDownstreamNodes(true);
         scheduler.submit(graph.getNodes().get(0));
         scheduler.submit(graph.getNodes().get(1));
         scheduler.run();
@@ -275,8 +291,9 @@ public void testAddTwoGraphsTogether() {
         }
         assertEquals(4,count);
 
+        scheduler.setQueueDownstreamNodes(true);
         scheduler.run();
-
+        // check the values of the Adds
         assertEquals(9.0,m.getPort(2).getValue());
     }
 }