diff --git a/internal/caches/storage_file.go b/internal/caches/storage_file.go index 321fedc..a8303ca 100644 --- a/internal/caches/storage_file.go +++ b/internal/caches/storage_file.go @@ -65,7 +65,8 @@ var sharedWritingFileKeyLocker = sync.Mutex{} var maxOpenFiles = NewMaxOpenFiles() -const maxOpenFilesSlowCost = 500 * time.Microsecond // 0.5ms +const maxOpenFilesSlowCost = 5000 * time.Microsecond // 0.5ms +const protectingLoadWhenDump = false // FileStorage 文件缓存 // 文件结构: diff --git a/internal/caches/storage_memory.go b/internal/caches/storage_memory.go index 3bb0e6d..90e4df6 100644 --- a/internal/caches/storage_memory.go +++ b/internal/caches/storage_memory.go @@ -438,16 +438,18 @@ func (this *MemoryStorage) startFlush() { if statCount == 100 { statCount = 0 - loadStat, err := load.Avg() - if err == nil && loadStat != nil { - if loadStat.Load1 > 10 { - writeDelayMS = 100 - } else if loadStat.Load1 > 3 { - writeDelayMS = 50 - } else if loadStat.Load1 > 2 { - writeDelayMS = 10 - } else { - writeDelayMS = 0 + if protectingLoadWhenDump { + loadStat, err := load.Avg() + if err == nil && loadStat != nil { + if loadStat.Load1 > 10 { + writeDelayMS = 100 + } else if loadStat.Load1 > 3 { + writeDelayMS = 50 + } else if loadStat.Load1 > 2 { + writeDelayMS = 10 + } else { + writeDelayMS = 0 + } } } }