diff --git a/example/main.go b/example/main.go
index d375917..53f6ad9 100644
--- a/example/main.go
+++ b/example/main.go
@@ -9,72 +9,52 @@
 )
 
 const (
-	BufferSize = 1024 * 64
-	BufferMask = BufferSize - 1
-	Iterations = 1000000 * 100
+	BufferSize   = 1024 * 64
+	BufferMask   = BufferSize - 1
+	Iterations   = 1000000 * 100
+	Reservations = 1
 )
 
-var ringBuffer = [BufferSize]int64{}
+var ring = [BufferSize]int64{}
 
 func main() {
 	runtime.GOMAXPROCS(2)
 
-	written, read := disruptor.NewCursor(), disruptor.NewCursor()
-	reader := disruptor.NewReader(read, written, written, SampleConsumer{})
+	controller := disruptor.Configure(BufferSize, SampleConsumer{}).Build()
+	controller.Start()
 
 	started := time.Now()
-	reader.Start()
-	publish(written, read)
-	reader.Stop()
+	publish(controller.Writer())
 	finished := time.Now()
+
+	controller.Stop()
 	fmt.Println(Iterations, finished.Sub(started))
 }
 
-const Reservations = 1
-
-func publish(written *disruptor.Cursor, upstream disruptor.Barrier) {
+func publish(writer *disruptor.Writer) {
 	sequence := disruptor.InitialSequenceValue
-	writer := disruptor.NewWriter(written, upstream, BufferSize)
 	for sequence <= Iterations {
-		sequence += Reservations
-		writer.Await(sequence)
-		ringBuffer[sequence&BufferMask] = sequence
+		sequence = writer.Reserve(Reservations)
+		ring[sequence&BufferMask] = sequence
 		writer.Commit(sequence, sequence)
 	}
 }
 
-// func publish(written *disruptor.Cursor, upstream disruptor.Barrier) {
+// func publish(writer *disruptor.Writer) {
 // 	sequence := disruptor.InitialSequenceValue
-// 	writer := disruptor.NewWriter(written, upstream, BufferSize)
 // 	for sequence <= Iterations {
-// 		sequence = writer.Reserve(Reservations)
-// 		ringBuffer[sequence&BufferMask] = sequence
+// 		sequence += Reservations
+// 		writer.Await(sequence)
+// 		ring[sequence&BufferMask] = sequence
 // 		writer.Commit(sequence, sequence)
 // 	}
 // }
 
-// func publish(written *disruptor.Cursor, upstream disruptor.Barrier) {
-// 	previous := disruptor.InitialSequenceValue
-// 	gate := disruptor.InitialSequenceValue
-
-// 	for previous <= Iterations {
-// 		next := previous + 1
-
-// 		for next-BufferSize > gate {
-// 			gate = upstream.Read(next)
-// 		}
-
-// 		ringBuffer[next&BufferMask] = next
-// 		written.Store(next)
-// 		previous = next
-// 	}
-// }
-
 type SampleConsumer struct{}
 
 func (this SampleConsumer) Consume(lower, upper int64) {
 	for lower <= upper {
-		message := ringBuffer[lower&BufferMask]
+		message := ring[lower&BufferMask]
 		if message != lower {
 			fmt.Println("Race condition", message, lower)
 			panic("Race condition")