diff --git a/utils/bytes_buffer_pool.go b/utils/bytes_buffer_pool.go index fe0066ed2..e57934553 100644 --- a/utils/bytes_buffer_pool.go +++ b/utils/bytes_buffer_pool.go @@ -15,18 +15,11 @@ var ( return &bytes.Buffer{} }, } - bytesBufferChan = make(chan *bytes.Buffer, 10) ) func BytesBufferGet() (data *bytes.Buffer) { - select { - case data = <-bytesBufferChan: - default: - data = bytesBufferPool.Get().(*bytes.Buffer) - } - + data = bytesBufferPool.Get().(*bytes.Buffer) data.Reset() - return data } @@ -34,10 +27,5 @@ func BytesBufferPut(data *bytes.Buffer) { if data == nil || len(data.Bytes()) > TooBigBlockSize { return } - - select { - case bytesBufferChan <- data: - default: - bytesBufferPool.Put(data) - } + bytesBufferPool.Put(data) }