Utilizing new shared writer.
diff --git a/example/example_producer.go b/example/example_producer.go
index 4ddd222..94b3095 100644
--- a/example/example_producer.go
+++ b/example/example_producer.go
@@ -2,7 +2,7 @@
import "github.com/smartystreets/go-disruptor"
-func publish(writer *disruptor.Writer) {
+func publish(writer *disruptor.SharedWriter) {
for {
sequence := writer.Reserve(ItemsToPublish)
diff --git a/example/main.go b/example/main.go
index 5db2b1c..e664b7b 100644
--- a/example/main.go
+++ b/example/main.go
@@ -10,7 +10,7 @@
MaxConsumersPerGroup = 1
MaxConsumerGroups = 2
ItemsToPublish = 4
- ReportingFrequency = 1000000 * 10 // 1 million * N
+ ReportingFrequency = 1000000 * 1 // 1 million * N
RingSize = 1024 * 16
RingMask = RingSize - 1
)
@@ -21,9 +21,9 @@
runtime.GOMAXPROCS(MaxConsumerGroups*MaxConsumersPerGroup + 1)
writerCursor := disruptor.NewCursor()
- writerBarrier := disruptor.NewBarrier(writerCursor)
+ writerBarrier := disruptor.NewSharedWriterBarrier(writerCursor, RingSize)
readerBarrier := startConsumerGroups(writerBarrier, writerCursor)
- writer := disruptor.NewWriter(writerCursor, RingSize, readerBarrier)
+ writer := disruptor.NewSharedWriter(writerBarrier, readerBarrier)
publish(writer)
}
