GC-optimierte Objektwiederverwendung mit typisiertem Puffer-Pooling via sync.Pool

package main
 
import (
	"bytes"
	"fmt"
	"sync"
)
 
type BufferPool struct {
	pool sync.Pool
}
 
func NewBufferPool(capacity int) *BufferPool {
	return &BufferPool{
		pool: sync.Pool{
			New: func() any {
				return bytes.NewBuffer(make([]byte, 0, capacity))
			},
		},
	}
}
 
func (p *BufferPool) Get() *bytes.Buffer {
	buf := p.pool.Get().(*bytes.Buffer)
	buf.Reset()
	return buf
}
 
func (p *BufferPool) Put(buf *bytes.Buffer) {
	// Prevent pooling bloated buffers to keep memory footprint bound
	if buf.Cap() > 64*1024 {
		return
	}
	p.pool.Put(buf)
}
 
func main() {
	bp := NewBufferPool(4096)
	buf := bp.Get()
	buf.WriteString("High-throughput stream processing")
	fmt.Println(buf.String())
	bp.Put(buf)
}