Fix lockfree queue size and full check

Signed-off-by: Coldwings <coldwings@me.com>
alibaba · Oct 25, 2023 · 4c40e98 · 4c40e98
1 parent fe71b20
commit 4c40e98
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/common/lockfree_queue.h b/common/lockfree_queue.h
@@ -58,6 +58,9 @@ struct Capacity_2expN<0> {
 template <>
 struct Capacity_2expN<1> : public Capacity_2expN<0> {};
 
+template <>
+struct Capacity_2expN<2> : public Capacity_2expN<0> {};
+
 struct PauseBase {};
 
 struct CPUPause : PauseBase {
@@ -136,7 +139,7 @@ class LockfreeRingQueueBase {
  bool check_empty(size_t h, size_t t) const { return h == t; }
 
  bool check_full(size_t h, size_t t) const {
- return check_mask_equal(h, t + 1);
+ return h != t && check_mask_equal(h, t);
  }
 
  size_t idx(size_t x) const { return x & mask; }