mirror of
https://github.com/Mrs4s/MiraiGo.git
synced 2025-06-18 21:45:04 +08:00
remove 256k & 128k pool
This commit is contained in:
parent
b398cec6a5
commit
2e6b21bfef
@ -90,38 +90,3 @@ func releaseZlibWriter(w *zlibWriter) {
|
|||||||
zlibPool.Put(w)
|
zlibPool.Put(w)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
const size256k = 256 * 1024
|
|
||||||
|
|
||||||
var b256kPool = sync.Pool{
|
|
||||||
New: func() interface{} {
|
|
||||||
return make128kSlicePointer()
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
|
||||||
// Get256KBytes 获取一个128k大小 []byte
|
|
||||||
func Get256KBytes() *[]byte {
|
|
||||||
buf := b256kPool.Get().(*[]byte)
|
|
||||||
// 因为 b256kPool 定义有 New 函数
|
|
||||||
// 所以 b256kPool.Get() 永不为 nil
|
|
||||||
// 不用判空
|
|
||||||
if cap(*buf) < size256k {
|
|
||||||
return make128kSlicePointer()
|
|
||||||
}
|
|
||||||
*buf = (*buf)[:size256k]
|
|
||||||
return buf
|
|
||||||
}
|
|
||||||
|
|
||||||
// Put256KBytes 放回一个128k大小 []byte
|
|
||||||
func Put256KBytes(b *[]byte) {
|
|
||||||
if cap(*b) < size256k || cap(*b) > 2*size256k { // 太大或太小的 []byte 不要放入
|
|
||||||
return
|
|
||||||
}
|
|
||||||
*b = (*b)[:cap(*b)]
|
|
||||||
b256kPool.Put(b)
|
|
||||||
}
|
|
||||||
|
|
||||||
func make128kSlicePointer() *[]byte {
|
|
||||||
data := make([]byte, size256k)
|
|
||||||
return &data
|
|
||||||
}
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user