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)
 }