Benchmarking only consumer without producer.
diff --git a/example/example_consumer.go b/example/example_consumer.go
index af1e0cd..dd09ea3 100644
--- a/example/example_consumer.go
+++ b/example/example_consumer.go
@@ -26,10 +26,10 @@
started = time.Now()
}
- if sequence != ringBuffer[sequence&RingMask] {
- message := ringBuffer[sequence&RingMask]
- panic(fmt.Sprintf("Sequence: %d, Message %d\n", sequence, message))
- }
+ // if sequence != ringBuffer[sequence&RingMask] {
+ // message := ringBuffer[sequence&RingMask]
+ // panic(fmt.Sprintf("Sequence: %d, Message %d\n", sequence, message))
+ // }
remaining--
sequence++
diff --git a/example/main.go b/example/main.go
index e4ee529..683f9c3 100644
--- a/example/main.go
+++ b/example/main.go
@@ -2,6 +2,7 @@
import (
"runtime"
+ "time"
"github.com/smartystreets/go-disruptor"
)
@@ -14,11 +15,15 @@
writerCursor := disruptor.NewCursor()
writerBarrier := disruptor.NewBarrier(writerCursor)
- readerCursors := startReaders(writerBarrier, writerCursor)
- readerBarrier := disruptor.NewBarrier(readerCursors...)
+ writerCursor.Store(disruptor.MaxSequenceValue)
+ startReaders(writerBarrier, writerCursor)
+ time.Sleep(time.Second * 10)
- writer := disruptor.NewWriter(writerCursor, RingSize, readerBarrier)
- publish(writer)
+ // readerCursors := startReaders(writerBarrier, writerCursor)
+ // readerBarrier := disruptor.NewBarrier(readerCursors...)
+
+ // writer := disruptor.NewWriter(writerCursor, RingSize, readerBarrier)
+ // publish(writer)
}
func startReaders(writerBarrier disruptor.Barrier, writerCursor *disruptor.Cursor) (readerCursors []*disruptor.Cursor) {
for i := 0; i < MaxConsumers; i++ {
