sig-pub/pkg/utils/misc/concurrent.go

package misc

import (
	"runtime/debug"
	"sig-pub/pkg/zlog"
)

func SafeGo(fn func()) {
	go func() {
		defer func() {
			if err := recover(); err != nil {
				zlog.Errorf("safe run error %v, stack info %v", err, string(debug.Stack()))
			}
		}()
		fn()
	}()
}