exegroup

Overview ¶

Package exegroup 管理1组执行单元的启动和终止;

使用举例:

新建 Group:

g := New()

新建默认 Group (内置信号处理):

g := Default()

新增1个 Actor, 通过 ctx 控制 Actor 退出:

g.New().WithName("do nothing").WithGo(func(ctx context.Context) error {
	<-ctx.Done()
	return ctx.Err()
})

新增1个 Actor, 通过 stopFunc 控制 Actor 退出:

server := &http.Server{Addr: ":80"}
inShutdown := &atomic.Bool{}
c := make(chan error, 1)
goFunc := func(_ context.Context) error {
	err := server.ListenAndServe()
	if inShutdown.Load() {
		err = <-c
	}
	return err
}
stopFunc := func(ctx context.Context) {
	inShutdown.Store(true)
	c <- server.Shutdown(ctx)
}
g.New().WithName("server").WithGoStop(goFunc, stopFunc)

启动 Group:

g.Run()

package main

import (
	"context"
	"log"

	"github.com/LIUKANG130/deep/exegroup"
)

func main() {
	g := exegroup.Default()
	g.New().WithName("do nothing").WithGo(func(ctx context.Context) error {
		<-ctx.Done()
		return ctx.Err()
	})
	log.Println("exit:", g.Run(context.Background()))
}

Output: