salmon

README

Salmon

[ants]

golang 协程池, 对 `github.com/panjf2000/ants/v2` 的二次封装

---

修改部分

• 代码内封装了 sync.WaitGroup.Add() 和 sync.WaitGroup.Done() 、sync.WaitGroup.Wait() 函数的自动调用，

  外部调用只需要关注业务逻辑

• 添加 cancel 函数，调用后，阻塞中的任务将不执行

Documentation

Index

• type Pool
  • func NewPool(size int) (Pool, error)
• type WorkFunc

Types

type Pool

type Pool interface {
	// Invoke 往池内提交任务
	Invoke(fn WorkFunc) error
	// Stop 手动停止任务
	Stop()
	// Wait 等待所有任务完成
	Wait()
}

Pool .

func NewPool

func NewPool(size int) (Pool, error)

NewPool .

type WorkFunc

type WorkFunc func(cancel func())

WorkFunc . 调用 cancel 后，阻塞中的任务将不执行