| package disruptor |
| |
| import "testing" |
| |
| func BenchmarkWriterReserve(b *testing.B) { |
| iterations := int64(b.N) |
| written, read := NewCursor(), NewCursor() |
| writer := NewWriter(written, read, 1024*64) |
| |
| b.ReportAllocs() |
| b.ResetTimer() |
| |
| for i := int64(0); i < iterations; i++ { |
| writer.Reserve(1) |
| read.sequence = i |
| } |
| } |
| |
| func BenchmarkWriterAwait(b *testing.B) { |
| iterations := int64(b.N) |
| written, read := NewCursor(), NewCursor() |
| writer := NewWriter(written, read, 1024*64) |
| |
| b.ReportAllocs() |
| b.ResetTimer() |
| |
| for i := int64(0); i < iterations; i++ { |
| writer.Await(i) |
| read.sequence = i |
| } |
| } |