diff --git a/binary/pool.go b/binary/pool.go index 02c8b2b9..305ae784 100644 --- a/binary/pool.go +++ b/binary/pool.go @@ -90,38 +90,3 @@ func releaseZlibWriter(w *zlibWriter) { 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 -}