Merge pull request #1 from tari-project/sb-fix-possible-race-cond

Fix for race condition from bus-queue repo

Author: CjS77

src/channel.rs

@@ -122,12 +122,15 @@ impl<T> Receiver<T> {
 
         // Reader has not read enough to keep up with (writer - buffer size) so
         // set the reader pointer to be (writer - buffer size)
-        if self.wi.get() - self.ri.get() >= self.size {
-            self.ri.set(self.wi.get() - self.size);
+        loop {
+            let val = self.buffer[self.ri.get() % self.size].load_full().unwrap();
+            if self.wi.get() - self.ri.get() > self.size {
+                self.ri.set(self.wi.get() - self.size);
+            } else {
+                self.ri.inc();
+                return Ok(val);
+            }
         }
-        let val = self.buffer[self.ri.get() % self.size].load_full().unwrap();
-        self.ri.inc();
-        Ok(val)
     }
 }