parallel

package

v0.0.8 Latest Latest Go to latest Published: Apr 9, 2024 License: MPL-2.0 Imports: 4 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package parallel 实现了可优雅关闭退出所有的actors Group

| ---> 执行actor
| ---> 退出处理

其类似errgroup, 但其不要求actor goroutines去理解上下文的意思，这样它可以在更多的场景下使用. 例如, 处理net.Listeners的connections, 或者从关闭的io.Reader中读取输入

This section is empty.

This section is empty.

func SignalActor(ctx context.Context, signals ...os.Signal) (execute func() error, interrupt func(error))

SignalActor actor监听signal信息, 当进程收到其中一个信号或者parent context被canceled

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

Group 收集一系列actor并且同时运行它们当其中某一个actor执行完，其他actors都会被中断执行

func (g *Group) Add(execute func() error, interrupt func(error))

Add 添加actor到group中。每个actor都必须被中断函数是抢占控制，换句话说，当中断函数执行，actor执行函数必须退出同时，必须保证执行函数退出后再调用中断函数也是安全的

首个执行完成的actor会中断所有正在运行的actor, 通过将error传给中断函数，最后被Run返回

func (g *Group) Run() error

Run 并行运行所有actors 当首个actor执行完成，其他的actor都会被中断只有所有actors退出后Run才返回，否则会一直会阻塞 Run最后返回时会返回首个退出的actor返回的error

type SignalError struct {
	Signal os.Signal
}

SignalError 当signalActor的execute函数收到信号退出是返回该错误

func (e SignalError) Error() string

Error 实现Error接口