x

Documentation

Index

• Constants
• type Pool
  • func NewPool[T comparable](capacity int) *Pool[T]
  • func (x *Pool[T]) Get() T
  • func (x *Pool[T]) Put(item T)
  • func (x *Pool[T]) WithFactory(factory func() T) *Pool[T]

Constants

const DefaultPoolCapacity = 2048

Types

type Pool

type Pool[T comparable] struct {
	// contains filtered or unexported fields
}

x.Pool is a specialized object pool implementation to replace sync.Pool. Unlike sync.Pool, x.Pool is backed by an MPMC queue, and objects in x.Pool will not be garbage collected for the lifetime of the pool, and its capacity is bounded. This is more useful if the objects in the pool should be long-lived.

func NewPool

func NewPool[T comparable](capacity int) *Pool[T]

func (*Pool[T]) Get

func (x *Pool[T]) Get() T

func (*Pool[T]) Put

func (x *Pool[T]) Put(item T)

func (*Pool[T]) WithFactory

func (x *Pool[T]) WithFactory(factory func() T) *Pool[T]