pool

Documentation

Index

• Constants
• func PutBytes(buf []byte)
• type BytesPool
  • func NewBytesPool() *BytesPool
• type WorkerPool
  • func NewWorkerPool() *WorkerPool

Constants

const (
	// DefaultAntsPoolSize sets up the capacity of worker pool.
	DefaultAntsPoolSize = 256 * 1024

	// ExpiryDuration is the interval time to clean up those expired workers.
	ExpiryDuration = 10 * time.Second

	// Nonblocking decides what to do when submitting a new job to a full worker pool: waiting for a available worker
	// or returning nil directly.
	Nonblocking = true
)

Functions

func PutBytes

func PutBytes(buf []byte)

PutBytes put bytes back to pool.

Types

type BytesPool

type BytesPool = pbytes.Pool

BytesPool is the alias of pbytes.Pool.

func NewBytesPool

func NewBytesPool() *BytesPool

NewBytesPool instantiates a *BytesPool that reuses slices which size is in logarithmic range [Lower, Upper].

type WorkerPool

type WorkerPool = ants.Pool

WorkerPool is the alias of ants.Pool.

func NewWorkerPool

func NewWorkerPool() *WorkerPool

NewWorkerPool instantiates a non-blocking *WorkerPool with the capacity of DefaultAntsPoolSize.