updated executor

twhuang-utah · twhuang-utah · commit 8dec2cd66fe9 · 2019-10-16T11:17:21.000-06:00
diff --git a/taskflow/core/executor.hpp b/taskflow/core/executor.hpp
@@ -603,7 +603,14 @@ inline void Executor::_schedule(PassiveVector<Node*>& nodes) {
     }
   }
 
-  _notifier.notify(false);
+  if(num_nodes >= _workers.size()) {
+    _notifier.notify(true);
+  }
+  else {
+    for(size_t k=0; k<num_nodes; ++k) {
+      _notifier.notify(false);
+    }
+  }
 }
 
 // Procedure: _init_module_node

Original file line number	Diff line number	Diff line change
`@@ -603,7 +603,14 @@ inline void Executor::_schedule(PassiveVector<Node*>& nodes) {`
`603`	`603`	`}`
`604`	`604`	`}`
`605`	`605`
`606`		`- _notifier.notify(false);`
	`606`	`+ if(num_nodes >= _workers.size()) {`
	`607`	`+ _notifier.notify(true);`
	`608`	`+ }`
	`609`	`+ else {`
	`610`	`+ for(size_t k=0; k<num_nodes; ++k) {`
	`611`	`+ _notifier.notify(false);`
	`612`	`+ }`
	`613`	`+ }`
`607`	`614`	`}`
`608`	`615`
`609`	`616`	`// Procedure: _init_module_node`