File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed
src/Dataflow/Engine/Scheduler Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change @@ -91,13 +91,8 @@ void ExecutionQueueManager::enqueueContext(ExecutionContextHandle context)
9191 {
9292 if (!executionLaunchThread_)
9393 start ();
94- // std::cout << "ctx queued" << std::endl;
9594 somethingToExecute_.conditionBroadcast ();
9695 }
97- else
98- {
99- // std::cout << "ctx queue is full" << std::endl;
100- }
10196}
10297
10398void ExecutionQueueManager::executeTopContext ()
@@ -107,14 +102,10 @@ void ExecutionQueueManager::executeTopContext()
107102 UniqueLock lock (executionMutex_.get ());
108103 while (0 == contextCount_)
109104 {
110- // std::cout << "waiting on launch thread lock " << boost::this_thread::get_id() << std::endl;
111105 somethingToExecute_.wait (lock);
112106 }
113- // std::cout << "consuming on launch thread " << boost::this_thread::get_id() << std::endl;
114107 if (contexts_.consume_one ([&](ExecutionContextHandle ctx) { if (currentExecutor_) currentExecutor_->execute (*ctx); }))
115108 contextCount_.fetch_sub (1 );
116- // std::cout << "sleeping on launch thread " << boost::this_thread::get_id() << std::endl;
117- // boost::this_thread::sleep(boost::posix_time::milliseconds(500));
118109 }
119110}
120111
You can’t perform that action at this time.
0 commit comments