diff --git a/DataStructures/ConcurrentQueue.h b/DataStructures/ConcurrentQueue.h index 28ebe9736..9d5b366f9 100644 --- a/DataStructures/ConcurrentQueue.h +++ b/DataStructures/ConcurrentQueue.h @@ -46,7 +46,6 @@ template class ConcurrentQueue [this] { return m_internal_queue.size() < m_internal_queue.capacity(); }); m_internal_queue.push_back(data); - m_mutex.unlock(); m_not_empty.notify_one(); } @@ -60,7 +59,6 @@ template class ConcurrentQueue { return !m_internal_queue.empty(); }); popped_value = m_internal_queue.front(); m_internal_queue.pop_front(); - m_mutex.unlock(); m_not_full.notify_one(); } @@ -73,7 +71,6 @@ template class ConcurrentQueue } popped_value = m_internal_queue.front(); m_internal_queue.pop_front(); - m_mutex.unlock(); m_not_full.notify_one(); return true; }