blob: 92193263ca2423302a7be3d22b6e198a0fd320f1 [file] [log] [blame]
package main
import (
"fmt"
"runtime"
"time"
"github.com/smartystreets/go-disruptor"
)
const (
BufferSize = 1024 * 64
BufferMask = BufferSize - 1
Iterations = 1000000 * 100
)
var ringBuffer = [BufferSize]int64{}
func main() {
runtime.GOMAXPROCS(2)
written, read := disruptor.NewCursor(), disruptor.NewCursor()
writer := disruptor.NewWriter(written, read, BufferSize)
reader := disruptor.NewReader(read, written, written, SampleConsumer{})
started := time.Now()
reader.Start()
publish(writer)
reader.Stop()
finished := time.Now()
fmt.Println(Iterations, finished.Sub(started))
}
func publish(writer *disruptor.Writer) {
for sequence := disruptor.InitialSequenceValue; sequence <= Iterations; {
sequence = writer.Reserve()
ringBuffer[sequence&BufferMask] = sequence
writer.Commit(sequence)
}
}
type SampleConsumer struct{}
func (this SampleConsumer) Consume(lower, upper int64) {
for lower <= upper {
message := ringBuffer[lower&BufferMask]
if message != lower {
fmt.Println("Race condition", message, lower)
panic("Race condition")
}
lower++
}
}