mirror of https://github.com/v2ray/v2ray-core
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
61 lines
1.1 KiB
61 lines
1.1 KiB
package alloc
|
|
|
|
import (
|
|
"sync"
|
|
)
|
|
|
|
type BufferPool struct {
|
|
chain chan []byte
|
|
allocator *sync.Pool
|
|
}
|
|
|
|
func NewBufferPool(bufferSize, poolSize int) *BufferPool {
|
|
pool := &BufferPool{
|
|
chain: make(chan []byte, poolSize),
|
|
allocator: &sync.Pool{
|
|
New: func() interface{} { return make([]byte, bufferSize) },
|
|
},
|
|
}
|
|
for i := 0; i < poolSize/2; i++ {
|
|
pool.chain <- make([]byte, bufferSize)
|
|
}
|
|
return pool
|
|
}
|
|
|
|
func (p *BufferPool) Allocate() *Buffer {
|
|
var b []byte
|
|
select {
|
|
case b = <-p.chain:
|
|
default:
|
|
b = p.allocator.Get().([]byte)
|
|
}
|
|
return &Buffer{
|
|
head: b,
|
|
pool: p,
|
|
Value: b[defaultOffset:],
|
|
offset: defaultOffset,
|
|
}
|
|
}
|
|
|
|
func (p *BufferPool) Free(buffer *Buffer) {
|
|
rawBuffer := buffer.head
|
|
if rawBuffer == nil {
|
|
return
|
|
}
|
|
select {
|
|
case p.chain <- rawBuffer:
|
|
default:
|
|
p.allocator.Put(rawBuffer)
|
|
}
|
|
}
|
|
|
|
const (
|
|
SmallBufferSize = 1024 - defaultOffset
|
|
BufferSize = 8*1024 - defaultOffset
|
|
LargeBufferSize = 64*1024 - defaultOffset
|
|
)
|
|
|
|
var smallPool = NewBufferPool(1024, 64)
|
|
var mediumPool = NewBufferPool(8*1024, 128)
|
|
var largePool = NewBufferPool(64*1024, 64)
|