Jason
5 years ago
1 changed files with 0 additions and 35 deletions
@ -1,35 +0,0 @@ |
|||
package core |
|||
|
|||
import ( |
|||
"sync" |
|||
) |
|||
|
|||
var pool *sync.Pool |
|||
|
|||
const BufSize = 32 * 1024 |
|||
|
|||
func SetBufferPool(p *sync.Pool) { |
|||
pool = p |
|||
} |
|||
|
|||
func NewBytes(size int) []byte { |
|||
if size <= BufSize { |
|||
return pool.Get().([]byte) |
|||
} else { |
|||
return make([]byte, size) |
|||
} |
|||
} |
|||
|
|||
func FreeBytes(b []byte) { |
|||
if len(b) >= BufSize { |
|||
pool.Put(b) |
|||
} |
|||
} |
|||
|
|||
func init() { |
|||
SetBufferPool(&sync.Pool{ |
|||
New: func() interface{} { |
|||
return make([]byte, BufSize) |
|||
}, |
|||
}) |
|||
} |
Loading…
Reference in new issue