coroutine

Documentation

Index

• func GoAndWait(fns ...func() error) error
• type Pool
  • func NewPool(poolCapacity int, taskCapacity int, printf func(formatter string, args ...any)) *Pool
  • func (pool *Pool) Run(task func())
  • func (pool *Pool) Wait()

Functions

func GoAndWait

func GoAndWait(fns ...func() error) error

1. 多协程并发执行时，一个协程抛出panic会导致所有协程全部退出，一个协程的panic只能该协程调用recover捕获，所以每个协程都要执行defer func() { recover() }() 2. 如果我们有批量的任务需要执行，肯定通过并发调用来提高性能，同时我们不希望其中一个调用失败就导致所有的任务都退出，而是要继续执行完其它的任务，封装co.GoAndWait接口

Types

type Pool

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

func NewPool

func NewPool(poolCapacity int, taskCapacity int, printf func(formatter string, args ...any)) *Pool

func (*Pool) Run

func (pool *Pool) Run(task func())

func (*Pool) Wait

func (pool *Pool) Wait()