decode_pool.go

package gojay

import (
	"io"
	"sync"
)

var decPool = sync.Pool{
	New: newDecoderPool,
}

func init() {
	for i := 0; i < 32; i++ {
		decPool.Put(NewDecoder(nil))
	}
}

// NewDecoder returns a new decoder.
// It takes an io.Reader implementation as data input.
func NewDecoder(r io.Reader) *Decoder {
	return &Decoder{
		called:   0,
		cursor:   0,
		keysDone: 0,
		err:      nil,
		r:        r,
		data:     make([]byte, 512),
		length:   0,
		isPooled: 0,
	}
}
func newDecoderPool() interface{} {
	return NewDecoder(nil)
}

// BorrowDecoder borrows a Decoder from the pool.
// It takes an io.Reader implementation as data input.
//
// In order to benefit from the pool, a borrowed decoder must be released after usage.
func BorrowDecoder(r io.Reader) *Decoder {
	return borrowDecoder(r, 512)
}
func borrowDecoder(r io.Reader, bufSize int) *Decoder {
	dec := decPool.Get().(*Decoder)
	dec.called = 0
	dec.keysDone = 0
	dec.cursor = 0
	dec.err = nil
	dec.r = r
	dec.length = 0
	dec.isPooled = 0
	if bufSize > 0 {
		dec.data = make([]byte, bufSize)
	}
	return dec
}

// Release sends back a Decoder to the pool.
// If a decoder is used after calling Release
// a panic will be raised with an InvalidUsagePooledDecoderError error.
func (dec *Decoder) Release() {
	dec.isPooled = 1
	decPool.Put(dec)
}

// ByteBuffer

const (
	defCap = 1024
)

type ByteBuffer struct {
	B []byte

	isReleased bool
}

func (b *ByteBuffer) Release() {
	putBytes(b)
}

func (b *ByteBuffer) Set(p []byte) {
	b.B = append(b.B[:0], p...)
}

func (b *ByteBuffer) Len() int {
	return len(b.B)
}

//Release s.e.
var bytesPool = sync.Pool{
	New: func() interface{} {
		return &ByteBuffer{B: make([]byte, defCap)}
	},
}

func getBytes(l int) (b *ByteBuffer) {
	b = bytesPool.Get().(*ByteBuffer)

	if cap(b.B) < l {
		b.B = make([]byte, l)
	} else {
		b.B = b.B[:l]
	}

	b.isReleased = false
	return b
}

func putBytes(b *ByteBuffer) {
	if !b.isReleased {

		b.isReleased = true
		bytesPool.Put(b)
	}
}