Asserting no race conditions.
diff --git a/example/example_consumer.go b/example/example_consumer.go
index 9f19705..1b32277 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 c44a5c7..e23f068 100644
--- a/example/main.go
+++ b/example/main.go
@@ -8,7 +8,7 @@
const (
MaxConsumersPerGroup = 1
- MaxConsumerGroups = 1
+ MaxConsumerGroups = 2
MaxProducers = 1
ItemsToPublish = 4
ReportingFrequency = 1000000 * 10 // 1 million * N
@@ -57,7 +57,7 @@
reader := disruptor.NewReader(read, written, upstream)
// constant time regardless of the number of items
- //go consume0(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
+ // go consume0(disruptor.NewSimpleReader(reader, NewExampleConsumerHandler()))
// TODO: wildly sporadic latency for single-item publish, e.g. 2 seconds, 65 ms, etc.
// faster for 2-3+ items per publish
