review/various changes

hpcc-systems · Jun 26, 2024 · 00087f9 · 00087f9
1 parent 36c6811
commit 00087f9
Show file tree

Hide file tree

Showing 3 changed files with 117 additions and 107 deletions.
diff --git a/system/jlib/jqueue.hpp b/system/jlib/jqueue.hpp
@@ -546,6 +546,8 @@ class DListOf
     }
 };
 
+// Lockfree Single Producer Single Conumser bounded queue implementation
+// No mutexes are required to interact with the queue, as long as there's a single consumer thread, and a single writer thread.
 template <typename T>
 class CSPSCQueue
 {
@@ -556,7 +558,10 @@ class CSPSCQueue
 
     inline size32_t increment(size32_t idx) const
     {
-        return (idx + 1) % maxCapacity;
+        size32_t next = idx+1;
+        if (next == maxCapacity)
+            next = 0;
+        return next;
     }
 public:
     CSPSCQueue()