updated executor

tsung-wei-huang · tsung-wei-huang · commit fb588cb2b570 · 2019-05-17T17:38:31.000-05:00
diff --git a/taskflow/core/executor.hpp b/taskflow/core/executor.hpp
@@ -822,7 +822,7 @@ std::future<void> Executor::run_until(Taskflow& f, P&& pred, C&& c) {
   }
 
   // Multi-threaded execution.
-  bool run_now {false};
+  //bool run_now {false};
   Topology* tpg;
   std::future<void> future;
   
@@ -834,16 +834,18 @@ std::future<void> Executor::run_until(Taskflow& f, P&& pred, C&& c) {
     future = tpg->_promise.get_future();
 
     if(f._topologies.size() == 1) {
-      run_now = true;
+      //run_now = true;
+      tpg->_bind(f._graph);
+      _schedule(tpg->_sources);     
     }
   }
   
   // Notice here calling schedule may cause the topology to be removed sonner 
   // before the function leaves.
-  if(run_now) {
-    tpg->_bind(f._graph);
-    _schedule(tpg->_sources);
-  }
+  //if(run_now) {
+  //  tpg->_bind(f._graph);
+  //  _schedule(tpg->_sources);
+  //}
 
   return future;
 }
