Add benchmark

tests/entry_benchmark_concurrency_test.go

@@ -0,0 +1,120 @@
+package tests
+
+import (
+	"log"
+	"testing"
+
+	sentinel "github.com/alibaba/sentinel-golang/api"
+)
+
+func Benchmark_Directly_Concurrency4(b *testing.B) {
+	initNumberWith200()
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(4)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomething()
+		}
+	})
+}
+func Benchmark_StatEntry_Concurrency4(b *testing.B) {
+	initNumberWith200()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(4)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomethingWithSentinel()
+		}
+	})
+}
+
+func Benchmark_Directly_Concurrency8(b *testing.B) {
+	initNumberWith200()
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(8)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomething()
+		}
+	})
+}
+func Benchmark_StatEntry_Concurrency8(b *testing.B) {
+	initNumberWith200()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(8)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomethingWithSentinel()
+		}
+	})
+}
+
+func Benchmark_Directly_Concurrency16(b *testing.B) {
+	initNumberWith200()
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(16)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomething()
+		}
+	})
+}
+func Benchmark_StatEntry_Concurrency16(b *testing.B) {
+	initNumberWith200()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(16)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomethingWithSentinel()
+		}
+	})
+}
+
+func Benchmark_Directly_Concurrency32(b *testing.B) {
+	initNumberWith200()
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(32)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomething()
+		}
+	})
+}
+func Benchmark_StatEntry_Concurrency32(b *testing.B) {
+	initNumberWith200()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	b.SetParallelism(32)
+	b.RunParallel(func(pb *testing.PB) {
+		for pb.Next() {
+			doSomethingWithSentinel()
+		}
+	})
+}

tests/entry_benchmark_test.go

@@ -0,0 +1,230 @@
+package tests
+
+import (
+	"fmt"
+	"log"
+	"math/rand"
+	"sort"
+	"testing"
+
+	sentinel "github.com/alibaba/sentinel-golang/api"
+)
+
+var numbers = make([]int, 0)
+
+func initNumberWith50() {
+	numbers = make([]int, 0, 50)
+	for i := 0; i < 50; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+
+func initNumberWith100() {
+	numbers = make([]int, 0, 100)
+	for i := 0; i < 100; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+
+func initNumberWith200() {
+	numbers = make([]int, 0, 200)
+	for i := 0; i < 200; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+
+func initNumberWith500() {
+	numbers = make([]int, 0, 500)
+	for i := 0; i < 500; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+
+func initNumberWith1000() {
+	numbers = make([]int, 0, 1000)
+	for i := 0; i < 1000; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+
+func initNumberWith2000() {
+	numbers = make([]int, 0, 2000)
+	for i := 0; i < 2000; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+func initNumberWith4000() {
+	numbers = make([]int, 0, 4000)
+	for i := 0; i < 4000; i++ {
+		numbers = append(numbers, rand.Int())
+	}
+}
+
+func doSomething() {
+	sort.Ints(numbers)
+	//rand.Shuffle(len(numbers), func(i, j int) { numbers[i], numbers[j] = numbers[j], numbers[i] })
+}
+
+func doSomethingWithSentinel() {
+	e, b := sentinel.Entry("benchmark_stat_entry")
+	if b != nil {
+		fmt.Println("Blocked")
+	} else {
+		doSomething()
+		e.Exit()
+	}
+}
+
+func Benchmark_Single_Directly_50(b *testing.B) {
+	initNumberWith50()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_50(b *testing.B) {
+	initNumberWith50()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}
+
+func Benchmark_Single_Directly_100(b *testing.B) {
+	initNumberWith100()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_100(b *testing.B) {
+	initNumberWith100()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}
+
+func Benchmark_Single_Directly_200(b *testing.B) {
+	initNumberWith200()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_200(b *testing.B) {
+	initNumberWith200()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}
+
+func Benchmark_Single_Directly_500(b *testing.B) {
+	initNumberWith500()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_500(b *testing.B) {
+	initNumberWith500()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}
+
+func Benchmark_Single_Directly_1000(b *testing.B) {
+	initNumberWith1000()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_1000(b *testing.B) {
+	initNumberWith1000()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}
+
+func Benchmark_Single_Directly_2000(b *testing.B) {
+	initNumberWith2000()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_2000(b *testing.B) {
+	initNumberWith2000()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}
+
+func Benchmark_Single_Directly_4000(b *testing.B) {
+	initNumberWith4000()
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomething()
+	}
+}
+func Benchmark_Single_StatEntry_4000(b *testing.B) {
+	initNumberWith4000()
+	// We should initialize Sentinel first.
+	err := sentinel.InitDefault()
+	if err != nil {
+		log.Fatalf("Unexpected error: %+v", err)
+	}
+	b.ReportAllocs()
+	b.ResetTimer()
+	for i := 0; i < b.N; i++ {
+		doSomethingWithSentinel()
+	}
+}