Experimenting with different writing techniques.
diff --git a/example/main.go b/example/main.go
index 9237fbb..3501919 100644
--- a/example/main.go
+++ b/example/main.go
@@ -33,6 +33,29 @@
}
func publish(written, read *disruptor.Cursor) {
+
+ // sequence := disruptor.InitialSequenceValue
+ // writer := &disruptor.Writer2{}
+
+ // // writer := disruptor.NewWriter(written, read, BufferSize)
+ // for sequence < Iterations {
+ // sequence = writer.Reserve()
+ // }
+
+ // sequence := disruptor.InitialSequenceValue
+ // writer := disruptor.NewWriter(written, read, BufferSize)
+
+ // for sequence <= Iterations {
+ // sequence = writer.Reserve()
+ // ringBuffer[sequence&BufferMask] = sequence
+ // written.Sequence = sequence
+ // // writer.Commit(sequence)
+ // }
+
+ // fmt.Println(writer.Gating())
+
+ gating := 0
+
previous := disruptor.InitialSequenceValue
gate := disruptor.InitialSequenceValue
@@ -42,12 +65,15 @@
for wrap > gate {
gate = read.Sequence
+ gating++
}
ringBuffer[next&BufferMask] = next
written.Sequence = next
previous = next
}
+
+ fmt.Println("Gating", gating)
}
type SampleConsumer struct{}