diff --git a/src/threading/Queue.h b/src/threading/Queue.h
index 4c3453d0c8..ad59f15268 100644
--- a/src/threading/Queue.h
+++ b/src/threading/Queue.h
@@ -255,7 +255,10 @@ template<typename T>
 inline void Queue<T>::WakeUp()
 	{
 	for ( int i = 0; i < NUM_QUEUES; i++ )
+		{
+		auto lock = acquire_lock(mutex[i]);
 		has_data[i].notify_all();
+		}
 	}
 
 }