Verified that all known race conditions are completely gone.
diff --git a/example/example_consumer.go b/example/example_consumer.go
index ac19ff4..6cbe712 100644
--- a/example/example_consumer.go
+++ b/example/example_consumer.go
@@ -32,7 +32,7 @@
panic(alert)
}
- // ringBuffer[sequence&RingMask] = sequence % 2
+ ringBuffer[sequence&RingMask] = sequence % 2
}
reader.Commit(lower, upper)
diff --git a/example/main.go b/example/main.go
index 0925935..6a991af 100644
--- a/example/main.go
+++ b/example/main.go
@@ -8,9 +8,9 @@
const (
MaxConsumersPerGroup = 1
- MaxConsumerGroups = 1
+ MaxConsumerGroups = 2
MaxProducers = 2
- ItemsToPublish = 4
+ ItemsToPublish = 2
ReportingFrequency = 1000000 * 10 // 1 million * N
RingSize = 1024 * 16
RingMask = RingSize - 1