routine

Documentation

Index

• type Pool
  • func NewPool(size, expiry int) (*Pool, error)
  • func (p *Pool) ReSize(size int)
  • func (p *Pool) Submit(task functinType, str interface{}) error
• type Worker

Types

type Pool

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

Pool accept the tasks from client,it limits the total of goroutines to a given number by recycling goroutines.

func NewPool

func NewPool(size, expiry int) (*Pool, error)

NewPool generates a instance of ants pool

func (*Pool) ReSize

func (p *Pool) ReSize(size int)

动态扩容或者缩小池容量 ReSize change the capacity of this pool

func (*Pool) Submit

func (p *Pool) Submit(task functinType, str interface{}) error

Submit submit a task to pool

type Worker

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

Worker is the actual executor who runs the tasks, it starts a goroutine that accepts tasks and performs function calls.