work

Documentation

Index

• type Pool
  • func New(maxGoroutine int) *Pool
  • func (p *Pool) Run(w Worker)
  • func (p *Pool) Shutdown()
• type Worker

Types

type Pool

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

func New

func New(maxGoroutine int) *Pool

func (*Pool) Run

func (p *Pool) Run(w Worker)

Run 提交工作到工作池

func (*Pool) Shutdown

func (p *Pool) Shutdown()

Shutdown 等待所有goroutine停止工作

type Worker

type Worker interface {
	Task()
}