signal only one

Coldwings · Jan 31, 2024 · d97edc3 · d97edc3
1 parent 294df85
commit d97edc3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/common/lockfree_queue.h b/common/lockfree_queue.h
@@ -578,7 +578,8 @@ class RingChannel : public QueueType {
         while (!push(x)) {
             Pause::pause();
         }
-        queue_sem.signal(idler.load(std::memory_order_acquire));
+        if (idler.load(std::memory_order_acquire))
+            queue_sem.signal(1);
     }
     T recv() {
         T x;