package disruptor

import "testing"

func BenchmarkReader(b *testing.B) {
	written := NewCursor()
	read := NewCursor()
	reader := NewReader(written, written, read)

	written.Store(1)

	iterations := int64(b.N)
	b.ReportAllocs()
	b.ResetTimer()

	for i := int64(0); i < iterations; i++ {
		_, upper := reader.Receive()
		reader.Commit(upper)
		read.Store(0)
	}
}