routine_pool

Documentation

Index

• type Pool
  • func New(size int, pf func(interface{}), options ...ants.Option) (*Pool, error)
  • func (s *Pool) Close() error
  • func (s *Pool) Invoke(args interface{}) error
  • func (s *Pool) Tune(size int)

Types

type Pool

type Pool struct {
	PoolWithFunc *ants.PoolWithFunc
	// contains filtered or unexported fields
}

Pool is a goroutine pool t

func New

func New(size int, pf func(interface{}), options ...ants.Option) (*Pool, error)

New creates a new goroutine pool

func (*Pool) Close

func (s *Pool) Close() error

Close closes this pool and releases the worker queue.

func (*Pool) Invoke

func (s *Pool) Invoke(args interface{}) error

Invoke submits a task to pool.

Note that you are allowed to call Pool.Invoke() from the current Pool.Invoke(), but what calls for special attention is that you will get blocked with the latest Pool.Invoke() call once the current Pool runs out of its capacity, and to avoid this, you should instantiate a PoolWithFunc with ants.WithNonblocking(true).

func (*Pool) Tune

func (s *Pool) Tune(size int)

Tune changes the capacity of this pool, note that it is noneffective to the infinite or pre-allocation pool.