chenyh
/
vRp.CD2g_test
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

对象缓冲池警告策略优化

This commit is contained in:
kercylan98 2023-05-19 17:02:09 +08:00
parent 83b61b9254
commit 750992cfe4
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
utils/synchronization/pool.go
View File

@ -28,6 +28,7 @@ type Pool[T any] struct {
bufferSize int bufferSize int
generator func() T generator func() T
releaser func(data T) releaser func(data T)
warn int
} }
func (slf *Pool[T]) Get() T { func (slf *Pool[T]) Get() T {
@ -39,7 +40,11 @@ func (slf *Pool[T]) Get() T {
return data return data
} }
slf.mutex.Unlock() slf.mutex.Unlock()
slf.warn++
if slf.warn >= 100 {
log.Warn("Pool", zap.String("Get", "the number of buffer members is insufficient, consider whether it is due to unreleased or inappropriate buffer size")) log.Warn("Pool", zap.String("Get", "the number of buffer members is insufficient, consider whether it is due to unreleased or inappropriate buffer size"))
slf.warn = 0
}
return slf.generator() return slf.generator()
} }
@ -54,6 +59,7 @@ func (slf *Pool[T]) Close() {
slf.bufferSize = 0 slf.bufferSize = 0
slf.generator = nil slf.generator = nil
slf.releaser = nil slf.releaser = nil
slf.warn = 0
slf.mutex.Unlock() slf.mutex.Unlock()
} }