add benchmark for parallel processing

shogo82148 · Dec 29, 2023 · 728f568 · 728f568
1 parent 5b0d4a5
commit 728f568
Showing 1 changed file with 17 additions and 0 deletions.
diff --git a/benchmark_test.go b/benchmark_test.go
@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"testing"
+	"time"
 )
 
 //go:noinline
@@ -56,3 +57,19 @@ func BenchmarkDoSuccess(b *testing.B) {
 		})
 	}
 }
+
+func BenchmarkDo_Parallel(b *testing.B) {
+	err := errors.New("error")
+	policy := &Policy{
+		MaxCount: 100,
+		Jitter:   1 * time.Nanosecond,
+	}
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			policy.Do(context.Background(), func() error {
+				dummyFunc()
+				return err
+			})
+		}
+	})
+}