From 4eccec6b849d45c5c1fff8db7ea99d2e68e266de Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Fri, 3 May 2024 18:03:15 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=BB=98=E8=AE=A4=E7=9A=84?= =?UTF-8?q?=E5=B9=B6=E5=8F=91=E8=AF=BB=E5=86=99=E7=BA=BF=E7=A8=8B=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/utils/fs/limiter.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/internal/utils/fs/limiter.go b/internal/utils/fs/limiter.go index c212a0a..818aeb3 100644 --- a/internal/utils/fs/limiter.go +++ b/internal/utils/fs/limiter.go @@ -8,8 +8,8 @@ import ( ) var maxThreads = runtime.NumCPU() -var WriterLimiter = NewLimiter(max(maxThreads, 8)) -var ReaderLimiter = NewLimiter(max(maxThreads, 8)) +var WriterLimiter = NewLimiter(max(maxThreads*8, 16)) +var ReaderLimiter = NewLimiter(max(maxThreads*8, 16)) type Limiter struct { threads chan struct{} @@ -19,11 +19,11 @@ type Limiter struct { } func NewLimiter(threads int) *Limiter { - if threads < 4 { - threads = 4 + if threads < 16 { + threads = 16 } - if threads > 64 { - threads = 64 + if threads > 1024 { + threads = 1024 } var threadsChan = make(chan struct{}, threads)