Reader implementations for alternate CPU architectures; updated TODO.
diff --git a/example/main.go b/example/main.go
index 32345b6..d93130e 100644
--- a/example/main.go
+++ b/example/main.go
@@ -26,7 +26,7 @@
readerCursors = append(readerCursors, readerCursor)
reader := disruptor.NewReader(writerBarrier, writerCursor, readerCursor)
- // wildly sporadic times for single-item publish, e.g. 2 seconds, 65 ms, etc.
+ // wildly sporadic latency for single-item publish, e.g. 2 seconds, 65 ms, etc.
// faster for 2-3+ items per publish
// go consume(reader)
diff --git a/reader_386.go b/reader_386.go
new file mode 100644
index 0000000..5f2a7d3
--- /dev/null
+++ b/reader_386.go
@@ -0,0 +1,5 @@
+package disruptor
+
+func (this *Reader) Commit(sequence int64) {
+ this.readerCursor.Store(sequence)
+}
diff --git a/reader_arm.go b/reader_arm.go
new file mode 100644
index 0000000..5f2a7d3
--- /dev/null
+++ b/reader_arm.go
@@ -0,0 +1,5 @@
+package disruptor
+
+func (this *Reader) Commit(sequence int64) {
+ this.readerCursor.Store(sequence)
+}
