diff --git a/internal/utils/fs/limiter.go b/internal/utils/fs/limiter.go index 818aeb3..76fb50e 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, 16)) -var ReaderLimiter = NewLimiter(max(maxThreads*8, 16)) +var WriterLimiter = NewLimiter(max(maxThreads*16, 32)) +var ReaderLimiter = NewLimiter(max(maxThreads*16, 32)) type Limiter struct { threads chan struct{} @@ -19,8 +19,8 @@ type Limiter struct { } func NewLimiter(threads int) *Limiter { - if threads < 16 { - threads = 16 + if threads < 32 { + threads = 32 } if threads > 1024 { threads = 1024