pool

Documentation

Index

• Constants
• type Options
• type Pool
  • func NewPool(options *Options) *Pool
  • func (p *Pool) Close()
  • func (p *Pool) Submit(callbackFunc func())
• type Task

Constants

const (
	DefaultPoolSize    = 1               // 线程池默认线程数
	DefaultIdleTimeout = time.Second * 5 // 如果5秒线程未被重复使用，则立即回收线程
)

pool default config params

Types

type Options

type Options struct {
	Size        int           // 线程池容量大小
	IdleTimeout time.Duration // 线程池线程idle时间，超过idle时间
}

Options default option struct

type Pool

type Pool struct {
	sync.Mutex
	Size int32 // 最大worker发数据

	IdleTimeout time.Duration // 线程闲置时间
	// contains filtered or unexported fields
}

Pool pool struct

func NewPool

func NewPool(options *Options) *Pool

NewPool create

func (*Pool) Close

func (p *Pool) Close()

Close the pool

func (*Pool) Submit

func (p *Pool) Submit(callbackFunc func())

Submit one task to pool

type Task

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

Task pool single task