work

Documentation

Index

• type Pool
  • func New(maxGoroutines 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
}

Pool 提供一个goroutine池，这个池可以完成任何已提交的Worker任务

func New

func New(maxGoroutines int) *Pool

New 创建一个新工作地

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()
}

Worker 必须满足接口类型