fix: 修复BufferPool性能测试遗漏buffer.Reset问题 (#18)

* fix: 修复BufferPool性能测试遗漏buffer.Reset问题 #17

* 更换为使用固定BufferPool

Author: thinkeridea

exstrings/join_int.go

@@ -9,7 +9,7 @@ import (
 	"github.com/thinkeridea/go-extend/pool"
 )
 
-var buffPool = pool.NewBuffer(64)
+var buffPool = pool.GetBuff64()
 
 // JoinInts 使用 sep 连接 []int 并返回连接的字符串
 func JoinInts(v []int, sep string) string {

pool/benchmark/buffer_test.go

@@ -51,6 +51,7 @@ func BenchmarkBufferSyncPool(b *testing.B) {
 	for i := 0; i < b.N; i++ {
 		data.Next()
 		bf := buff.Get().(*bytes.Buffer)
+		bf.Reset()
 		bf.Write(data.Value.([]byte))
 
 		idx := i % 20
@@ -89,6 +90,7 @@ func BenchmarkBufferFixedSizeSyncPool(b *testing.B) {
 	data := make([]byte, 50)
 	for i := 0; i < b.N; i++ {
 		bf := buff.Get().(*bytes.Buffer)
+		bf.Reset()
 		bf.Write(data)
 
 		idx := i % 20

pool/buffer.go

@@ -43,12 +43,15 @@ type buffer struct {
 	calls       [bucketSize]uint32
 }
 
+// NewBuffer 创建一个动态评估需求容量的 BufferPool，它们共享一个底层 bytes.Buffer 区间池
+// Deprecated: 这是错误测试产生的结果，它并没有相较 sync.Pool 有明显优势，详细参看: https://github.com/thinkeridea/go-extend/issues/17
 func NewBuffer(size int) BufferPool {
 	b := &buffer{}
 	b.index = uint32(buffBucketIndex(size))
 	return b
 }
 
+// Get 从 Pool 中获取一个 *bytes.Buffer 实例, 该实例已经被 Reset
 func (p *buffer) Get() *bytes.Buffer {
 	idx := atomic.LoadUint32(&p.index)
 	v := buffBucket[idx].Get()
@@ -61,6 +64,7 @@ func (p *buffer) Get() *bytes.Buffer {
 	return bytes.NewBuffer(make([]byte, 0, minSize<<idx))
 }
 
+// Put 把 *bytes.Buffer 放回 Pool 中
 func (p *buffer) Put(b *bytes.Buffer) {
 	if b.Cap() <= maxSize {
 		buffBucket[buffBucketIndex(b.Cap())].Put(b)