Moved constants; removed duplicate counter.
diff --git a/example/consumer_handler.go b/example/consumer_handler.go
index caa9f39..33980bf 100644
--- a/example/consumer_handler.go
+++ b/example/consumer_handler.go
@@ -17,3 +17,5 @@
panic(fmt.Sprintf("Race condition--Sequence: %d, Message: %d\n", sequence, message))
}
}
+
+const Mod = 1000000 * 10 // 1 million * N
diff --git a/example/publisher.go b/example/publisher.go
index 533350b..db07caa 100644
--- a/example/publisher.go
+++ b/example/publisher.go
@@ -3,12 +3,9 @@
import "bitbucket.org/jonathanoliver/go-disruptor"
func publish(sequencer *disruptor.SingleProducerSequencer) {
- for sequence := int64(0); sequence < MaxIterations; sequence++ {
- sequencer.Next(1)
+ for {
+ sequence := sequencer.Next(1)
ringBuffer[sequence&RingMask] = sequence
sequencer.Publish(sequence)
}
}
-
-const MaxIterations = disruptor.MaxSequenceValue
-const Mod = 1000000 * 10 // 1 million * N
diff --git a/example/ring_buffer.go b/example/ring_buffer.go
index a8ea340..5b1419d 100644
--- a/example/ring_buffer.go
+++ b/example/ring_buffer.go
@@ -1,6 +1,8 @@
package main
-const RingSize = 1024 * 16
-const RingMask = RingSize - 1
+const (
+ RingSize = 1024 * 16
+ RingMask = RingSize - 1
+)
var ringBuffer [RingSize]int64
