diff options
| author | chrislu <chris.lu@gmail.com> | 2024-01-27 14:46:12 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-01-27 14:46:12 -0800 |
| commit | fa835c93195d9effee2d513ce628bce87a5f3201 (patch) | |
| tree | 0787a3b977e09dc59bb85e66a60370d91f733b19 | |
| parent | b6de35cdb276057df37c588c7b7ac37563e41fb1 (diff) | |
| download | seaweedfs-fa835c93195d9effee2d513ce628bce87a5f3201.tar.xz seaweedfs-fa835c93195d9effee2d513ce628bce87a5f3201.zip | |
Update buffered_queue_test.go
| -rw-r--r-- | weed/util/buffered_queue/buffered_queue_test.go | 16 |
1 files changed, 6 insertions, 10 deletions
diff --git a/weed/util/buffered_queue/buffered_queue_test.go b/weed/util/buffered_queue/buffered_queue_test.go index c4236cd40..0dc96a083 100644 --- a/weed/util/buffered_queue/buffered_queue_test.go +++ b/weed/util/buffered_queue/buffered_queue_test.go @@ -86,15 +86,11 @@ func BenchmarkBufferedQueue(b *testing.B) { queue := NewBufferedQueue[Job[string]](1024, true) - b.Run("Enqueue", func(b *testing.B) { - for i := 0; i < b.N; i++ { - queue.Enqueue(Job[string]{ID: i, Action: "task", Data: "data"}) - } - }) + for i := 0; i < b.N; i++ { + queue.Enqueue(Job[string]{ID: i, Action: "task", Data: "data"}) + } + for i := 0; i < b.N; i++ { + _, _ = queue.Dequeue() + } - b.Run("Dequeue", func(b *testing.B) { - for i := 0; i < b.N; i++ { - _, _ = queue.Dequeue() - } - }) } |