The goroutine execution wrapper
the user only needs to pass the corresponding func to
the wrap method to execute (supports safe execution),
and supports waiting for all coroutines to complete execution.
package main
import (
"log"
"github.com/go-god/wrapper/factory"
)
func main() {
wrapper := factory.New(factory.ChWrapper, 2)
wrapper.Wrap(func() {
log.Println("chan wrapper: 1111")
})
wrapper.Wrap(func() {
log.Println("chan wrapper: 2222")
})
wrapper.Wait()
// factory.WgWrapper No need to pass second parameter.
wg := factory.New(factory.WgWrapper)
wg.Wrap(func() {
log.Println("wg wrapper:1111")
})
wg.Wrap(func() {
log.Println("wg wrapper:2222")
})
wg.WrapWithRecover(func() {
log.Println("wg wrapper:3333")
panic("mock panic:abc")
})
wg.Wait()
}
// output:
// 2022/01/09 22:47:48 chan wrapper: 2222
// 2022/01/09 22:47:48 chan wrapper: 1111
// 2022/01/09 22:47:48 wg wrapper:3333
// 2022/01/09 22:47:48 wg wrapper:1111
// 2022/01/09 22:47:48 wrapper exec recover:mock panic:abc
// 2022/01/09 22:47:48 wg wrapper:2222