From d6ceccc52ea7b11bcb063e768806e7e63f8987f9 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Sun, 1 May 2022 10:40:19 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=9F=BA=E5=87=86=E6=B5=8B?= =?UTF-8?q?=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/compressions/writer_gzip_test.go | 28 +++++++++++++++++++++++ 1 file changed, 28 insertions(+) diff --git a/internal/compressions/writer_gzip_test.go b/internal/compressions/writer_gzip_test.go index e805e42..71bc90f 100644 --- a/internal/compressions/writer_gzip_test.go +++ b/internal/compressions/writer_gzip_test.go @@ -34,3 +34,31 @@ func BenchmarkGzipWriter_Write(b *testing.B) { _ = writer.Close() } } + +func BenchmarkGzipWriter_Write_Parallel(b *testing.B) { + var data = []byte(strings.Repeat("A", 1024)) + + b.RunParallel(func(pb *testing.PB) { + for pb.Next() { + var buf = &bytes.Buffer{} + writer, err := compressions.NewGzipWriter(buf, 5) + if err != nil { + b.Fatal(err) + } + + for j := 0; j < 100; j++ { + _, err = writer.Write(data) + if err != nil { + b.Fatal(err) + } + + /**err = writer.Flush() + if err != nil { + b.Fatal(err) + }**/ + } + + _ = writer.Close() + } + }) +}