Browse Source

Merge pull request #1221 from paullouisageneau/fix-notify-queue-limit

Fix missing notify on queue limit preventing thread from waking up
Paul-Louis Ageneau 1 year ago
parent
commit
ed9a328876
1 changed files with 1 additions and 0 deletions
  1. 1 0
      src/impl/queue.hpp

+ 1 - 0
src/impl/queue.hpp

@@ -105,6 +105,7 @@ template <typename T> optional<T> Queue<T>::pop() {
 	mAmount -= mAmountFunction(mQueue.front());
 	mAmount -= mAmountFunction(mQueue.front());
 	optional<T> element{std::move(mQueue.front())};
 	optional<T> element{std::move(mQueue.front())};
 	mQueue.pop();
 	mQueue.pop();
+	mPushCondition.notify_one();
 	return element;
 	return element;
 }
 }