pool

Documentation

Index

• Constants
• type GoroutinePool
  • func NewGoroutinePool(opts ...PoolOption) *GoroutinePool
  • func (p *GoroutinePool) Close()
  • func (p *GoroutinePool) Submit(task f) error
• type PoolOption
  • func WithCapacity(capacity int32) PoolOption
  • func WithTimeout(timeout time.Duration) PoolOption
• type Worker
  • func (w *Worker) Close()

Constants

const (
	DefaultCapacity = 10
	DefaultTimeOut  = 30 * time.Second
)

Types

type GoroutinePool

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

func NewGoroutinePool

func NewGoroutinePool(opts ...PoolOption) *GoroutinePool

func (*GoroutinePool) Close

func (p *GoroutinePool) Close()

func (*GoroutinePool) Submit

func (p *GoroutinePool) Submit(task f) error

Submit 提交执行的任务

type PoolOption

type PoolOption func(pool *GoroutinePool)

func WithCapacity

func WithCapacity(capacity int32) PoolOption

func WithTimeout

func WithTimeout(timeout time.Duration) PoolOption

type Worker

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

Worker 对协程进行封装的worker,每一个worker绑定一个goroutine

func (*Worker) Close

func (w *Worker) Close()