Additional testing.
diff --git a/example/main.go b/example/main.go
index bd19d4e..a0612a2 100644
--- a/example/main.go
+++ b/example/main.go
@@ -29,4 +29,4 @@
return
}
-const MaxConsumers int = 2
+const MaxConsumers int = 1
diff --git a/example/publisher.go b/example/publisher.go
index 12756d4..c8deda6 100644
--- a/example/publisher.go
+++ b/example/publisher.go
@@ -23,4 +23,4 @@
}
const MaxIterations = disruptor.MaxSequenceValue
-const Mod = 1000000 * 10 // 1 million * N
+const Mod = 1000000 * 100 // 1 million * N
diff --git a/example/ring_buffer.go b/example/ring_buffer.go
index 193dc53..a8ea340 100644
--- a/example/ring_buffer.go
+++ b/example/ring_buffer.go
@@ -1,6 +1,6 @@
package main
-const RingSize = 1024 * 128
+const RingSize = 1024 * 16
const RingMask = RingSize - 1
var ringBuffer [RingSize]int64
diff --git a/sequence_amd64.go b/sequence_amd64.go
index 3e2419b..431b38e 100644
--- a/sequence_amd64.go
+++ b/sequence_amd64.go
@@ -1,10 +1,10 @@
package disruptor
func (this *Sequence) Store(value int64) {
- (*this)[SequencePayloadIndex] = value
+ this[SequencePayloadIndex] = value
}
func (this *Sequence) Load() int64 {
- return (*this)[SequencePayloadIndex] // scheduler causes atomic load to run faster?
+ return this[SequencePayloadIndex]
}
const FillCPUCacheLine uint8 = 8
