[sched] finished Single Thread consistency job execution

Author: pplux

LICENSE

@@ -33,13 +33,15 @@ ifeq ($(UNAME_S),Linux)
   endif
 endif
 
-px_sched_examples = px_sched_example1 px_sched_example2 px_sched_example3 px_sched_example4 px_sched_example5 px_sched_example6 px_sched_example7
+px_sched_examples = px_sched_example1 px_sched_example2 px_sched_example3 px_sched_example4 px_sched_example5 px_sched_example6 px_sched_example7 px_sched_example8
 px_render_examples = px_render_example_imgui #WIP: px_render_example_rtt px_render_example_triangle
 
 all: $(px_sched_examples) $(px_render_examples)
 
 $(px_sched_examples): %: %.cpp
 	$(CXX) $(CXXFLAGS) -o $@ $< $(LDFLAGS)
+	$(CXX) -DPX_SCHED_CONFIG_SINGLE_THREAD $(CXXFLAGS) -o $@_noMT $< $(LDFLAGS)
+
 
 $(px_render_examples): %: %.cpp
 	$(CXX) -std=c++14 -fpermissive -D linux -g -O2 -I . -o $@ $< $(LDFLAGS) -ldl -lX11
@@ -56,4 +58,14 @@ tests: $(px_sched_examples)
 	./px_sched_example5 
 	./px_sched_example6 
 	./px_sched_example7
+	./px_sched_example8
 	@echo "ALL px_sched_examples executed"
+	./px_sched_example1_noMT	
+	./px_sched_example2_noMT 
+	./px_sched_example3_noMT 
+	./px_sched_example4_noMT 
+	./px_sched_example5_noMT 
+	./px_sched_example6_noMT 
+	./px_sched_example7_noMT
+	./px_sched_example8_noMT
+	@echo "ALL px_sched_examples executed (no MT)"

README.md

@@ -0,0 +1,42 @@
+// Example-8:
+// Job order (mainly to check Single Threaded implementation) 
+
+#define PX_SCHED_IMPLEMENTATION 1
+#include "../px_sched.h"
+#include <cassert>
+
+int main(int, char **) {
+  px_sched::Scheduler schd;
+  schd.init();
+
+  // (a) Sync objects can be used later to wait for them
+  px_sched::Sync start;
+  px_sched::Sync middle;
+  px_sched::Sync end;
+  schd.incrementSync(&start);
+
+  schd.incrementSync(&middle);
+  size_t data[128] = {};
+  schd.runAfter(middle, [&data]{
+    printf("Checking...\n");
+    for(size_t i = 0; i < 128; ++i) {
+      assert(data[i] == i*2);
+    }
+  }, &end);
+  for(size_t i = 0; i < 128; ++i) {
+    schd.runAfter(start,[i, &data] () mutable {
+      printf("Running %lu\n",i);
+      data[i] = i*2;
+    }, &middle);
+  }
+  schd.decrementSync(&middle);
+  assert(data[127] == 0);
+  // start now
+  schd.decrementSync(&start);
+  printf("Waiting for tasks to finish...\n");
+  schd.waitFor(end); // wait for all tasks to finish
+  assert(data[127] == 254);
+  printf("Waiting for tasks to finish...DONE \n");
+
+  return 0;
+}