From 130519be7166aa5f56127cbfb7cd07e00ba59ea2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= Date: Sun, 20 Mar 2022 18:33:51 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=B5=8B=E8=AF=95=E7=94=A8?= =?UTF-8?q?=E4=BE=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/compressions/writer_brotli_test.go | 30 +++++++++++++++++++-- 1 file changed, 28 insertions(+), 2 deletions(-) diff --git a/internal/compressions/writer_brotli_test.go b/internal/compressions/writer_brotli_test.go index a56e7de..c047805 100644 --- a/internal/compressions/writer_brotli_test.go +++ b/internal/compressions/writer_brotli_test.go @@ -35,6 +35,33 @@ func BenchmarkBrotliWriter_Write(b *testing.B) { } } +func BenchmarkBrotliWriter_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.NewBrotliWriter(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() + } + }) +} func BenchmarkBrotliWriter_Write_Small(b *testing.B) { var data = []byte(strings.Repeat("A", 16)) @@ -62,7 +89,6 @@ func BenchmarkBrotliWriter_Write_Small(b *testing.B) { } } - func BenchmarkBrotliWriter_Write_Large(b *testing.B) { var data = []byte(strings.Repeat("A", 4096)) @@ -87,4 +113,4 @@ func BenchmarkBrotliWriter_Write_Large(b *testing.B) { _ = writer.Close() } -} \ No newline at end of file +}