Big simplification and improvement of the entity collection system, reducing unneeded steps for packages

1 files changed, 8 insertions, 1 deletions

diff --git a/src/queue.cpp b/src/queue.cpp
index da3cef687..4d7c0f052 100644
--- a/src/queue.cpp
+++ b/src/queue.cpp
@@ -64,6 +64,10 @@ void mpmc_destroy(MPMCQueue<T> *q) {
 
 template <typename T>
 isize mpmc_enqueue(MPMCQueue<T> *q, T const &data) {
+	if (q->mask == 0) {
+		return -1;
+	}
+
 	isize head_idx = q->head_idx.load(std::memory_order_relaxed);
 
 	for (;;) {
@@ -101,9 +105,12 @@ isize mpmc_enqueue(MPMCQueue<T> *q, T const &data) {
 	}
 }
 
-
 template <typename T>
 bool mpmc_dequeue(MPMCQueue<T> *q, T *data_) {
+	if (q->mask == 0) {
+		return false;
+	}
+
 	isize tail_idx = q->tail_idx.load(std::memory_order_relaxed);
 
 	for (;;) {