提交 a74eb160 编写于 作者: G gineshidalgo99

Queue bug fixed: Notify_all vs. one

上级 61404f11
...@@ -440,7 +440,7 @@ namespace op ...@@ -440,7 +440,7 @@ namespace op
return false; return false;
mTQueue.emplace(tDatums); mTQueue.emplace(tDatums);
mConditionVariable.notify_one(); mConditionVariable.notify_all();
return true; return true;
} }
catch (const std::exception& e) catch (const std::exception& e)
...@@ -459,7 +459,7 @@ namespace op ...@@ -459,7 +459,7 @@ namespace op
return false; return false;
mTQueue.push(tDatums); mTQueue.push(tDatums);
mConditionVariable.notify_one(); mConditionVariable.notify_all();
return true; return true;
} }
catch (const std::exception& e) catch (const std::exception& e)
...@@ -478,7 +478,7 @@ namespace op ...@@ -478,7 +478,7 @@ namespace op
return false; return false;
mTQueue.pop(); mTQueue.pop();
mConditionVariable.notify_one(); mConditionVariable.notify_all();
return true; return true;
} }
catch (const std::exception& e) catch (const std::exception& e)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册