Pool sliding windows

compress_notjs.go

@@ -115,16 +115,31 @@ func putFlateWriter(w *flate.Writer) {
 }
 
 type slidingWindow struct {
-	r   io.Reader
 	buf []byte
 }
 
+var swPool = map[int]*sync.Pool{}
+
 func newSlidingWindow(n int) *slidingWindow {
+	p, ok := swPool[n]
+	if !ok {
+		p = &sync.Pool{}
+		swPool[n] = p
+	}
+	sw, ok := p.Get().(*slidingWindow)
+	if ok {
+		return sw
+	}
 	return &slidingWindow{
 		buf: make([]byte, 0, n),
 	}
 }
 
+func returnSlidingWindow(sw *slidingWindow) {
+	sw.buf = sw.buf[:0]
+	swPool[cap(sw.buf)].Put(sw)
+}
+
 func (w *slidingWindow) write(p []byte) {
 	if len(p) >= cap(w.buf) {
 		w.buf = w.buf[:cap(w.buf)]

read.go

@@ -110,6 +110,10 @@ func (mr *msgReader) returnFlateReader() {
 func (mr *msgReader) close() {
 	mr.c.readMu.Lock(context.Background())
 	mr.returnFlateReader()
+
+	if mr.dict != nil {
+		returnSlidingWindow(mr.dict)
+	}
 }
 
 func (mr *msgReader) flateContextTakeover() bool {