recycler

Documentation

Overview

recycler

Index

• Constants
• Variables
• func AllocBytebuf() *bytes.Buffer
• func FreeBytebuf(buf *bytes.Buffer)
• func GetTimer(timeout time.Duration) *time.Timer
• func GiveTimer(t *time.Timer)
• type Recycler
  • func NewRecycler(backlog int, ocf func() interface{}, name string) *Recycler
  • func (this *Recycler) Close()
  • func (this *Recycler) Get() interface{}
  • func (this *Recycler) Give(i interface{})

Constants

const (
	NewTimerDefaultDuration time.Duration = time.Minute
	TimerRecyclerBacklog    int           = 128
)

const (
	BytebufRecyclerBacklog int = 128
)

Variables

var BytebufRecycler = NewRecycler(
	BytebufRecyclerBacklog,
	func() interface{} {
		return bytes.NewBuffer(nil)
	},
	"bytebuf_recycler",
)

var RecyclerBacklogDefault int = 5

var RecyclerMgr = &recyclerMgr{
	recyclers: make(map[interface{}]*Recycler),
	lock:      new(sync.Mutex),
}

var TimerRecycler = NewRecycler(
	TimerRecyclerBacklog,
	func() interface{} {
		return time.NewTimer(NewTimerDefaultDuration)
	},
	"timer_recycler",
)

Functions

func AllocBytebuf

func AllocBytebuf() *bytes.Buffer

func FreeBytebuf

func FreeBytebuf(buf *bytes.Buffer)

func GetTimer

func GetTimer(timeout time.Duration) *time.Timer

func GiveTimer

func GiveTimer(t *time.Timer)

Types

type Recycler

type Recycler struct {
	// contains filtered or unexported fields
}

func NewRecycler

func NewRecycler(backlog int, ocf func() interface{}, name string) *Recycler

func (*Recycler) Close

func (this *Recycler) Close()

func (*Recycler) Get

func (this *Recycler) Get() interface{}

func (*Recycler) Give

func (this *Recycler) Give(i interface{})