forked from Mrs4s/MiraiGo
/
pool.go
91 lines (80 loc) · 1.55 KB
/
pool.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
package binary
import (
"bytes"
"compress/gzip"
"compress/zlib"
"sync"
)
var bufferPool = sync.Pool{
New: func() any {
return new(Writer)
},
}
// SelectWriter 从池中取出一个 Writer
func SelectWriter() *Writer {
// 因为 bufferPool 定义有 New 函数
// 所以 bufferPool.Get() 永不为 nil
// 不用判空
return bufferPool.Get().(*Writer)
}
// PutWriter 将 Writer 放回池中
func PutWriter(w *Writer) {
// See https://golang.org/issue/23199
const maxSize = 32 * 1024
if (*bytes.Buffer)(w).Cap() < maxSize { // 对于大Buffer直接丢弃
w.Reset()
bufferPool.Put(w)
}
}
var gzipPool = sync.Pool{
New: func() any {
buf := new(bytes.Buffer)
w := gzip.NewWriter(buf)
return &GzipWriter{
w: w,
buf: buf,
}
},
}
func AcquireGzipWriter() *GzipWriter {
ret := gzipPool.Get().(*GzipWriter)
ret.buf.Reset()
ret.w.Reset(ret.buf)
return ret
}
func ReleaseGzipWriter(w *GzipWriter) {
// See https://golang.org/issue/23199
const maxSize = 1 << 16
if w.buf.Cap() < maxSize {
w.buf.Reset()
gzipPool.Put(w)
}
}
type zlibWriter struct {
w *zlib.Writer
buf *bytes.Buffer
}
var zlibPool = sync.Pool{
New: func() any {
buf := new(bytes.Buffer)
w := zlib.NewWriter(buf)
return &zlibWriter{
w: w,
buf: buf,
}
},
}
func acquireZlibWriter() *zlibWriter {
ret := zlibPool.Get().(*zlibWriter)
ret.buf.Reset()
ret.w.Reset(ret.buf)
return ret
}
func releaseZlibWriter(w *zlibWriter) {
// See https://golang.org/issue/23199
const maxSize = 1 << 16
if w.buf.Cap() < maxSize {
w.buf.Reset()
zlibPool.Put(w)
}
}