(b *testing.B)
| 606 | } |
| 607 | |
| 608 | func BenchmarkQueueDequeue(b *testing.B) { |
| 609 | // Open test database |
| 610 | file := fmt.Sprintf("test_db_%d", time.Now().UnixNano()) |
| 611 | q, err := OpenQueue(file) |
| 612 | if err != nil { |
| 613 | b.Error(err) |
| 614 | } |
| 615 | defer q.Drop() |
| 616 | |
| 617 | // Fill with dummy data |
| 618 | for n := 0; n < b.N; n++ { |
| 619 | if _, err = q.Enqueue([]byte("value")); err != nil { |
| 620 | b.Error(err) |
| 621 | } |
| 622 | } |
| 623 | |
| 624 | // Start benchmark |
| 625 | b.ResetTimer() |
| 626 | b.ReportAllocs() |
| 627 | |
| 628 | for n := 0; n < b.N; n++ { |
| 629 | _, _ = q.Dequeue() |
| 630 | } |
| 631 | } |