111

Author: lvan100

conf/bind.go

@@ -27,8 +27,8 @@ import (
 )
 
 var (
-	ErrNotExist      = errors.New("not exist")
-	ErrInvalidSyntax = errors.New("invalid syntax")
+	ErrNotExist      = util.FormatError(nil, "not exist")
+	ErrInvalidSyntax = util.FormatError(nil, "invalid syntax")
 )
 
 // ParsedTag represents a parsed configuration tag that encodes

util/goutil/goutil.go

@@ -28,15 +28,16 @@ package goutil
 
 import (
 	"context"
-	"errors"
 	"fmt"
 	"runtime/debug"
 	"sync"
+
+	"github.com/go-spring/spring-base/util"
 )
 
 // OnPanic is a global callback function triggered when a panic occurs.
-var OnPanic = func(ctx context.Context, r any) {
-	fmt.Printf("panic: %v\n%s\n", r, debug.Stack())
+var OnPanic = func(ctx context.Context, r any, stack []byte) {
+	fmt.Printf("panic: %v\n%s\n", r, stack)
 }
 
 /********************************** go ***************************************/
@@ -72,7 +73,7 @@ func Go(ctx context.Context, f func(ctx context.Context)) *Status {
 		defer func() {
 			if r := recover(); r != nil {
 				if OnPanic != nil {
-					OnPanic(ctx, r)
+					OnPanic(ctx, r, debug.Stack())
 				}
 			}
 		}()
@@ -81,24 +82,6 @@ func Go(ctx context.Context, f func(ctx context.Context)) *Status {
 	return s
 }
 
-// GoFunc runs a goroutine safely with panic recovery.
-// It ensures the process does not crash due to an uncaught panic in the goroutine.
-func GoFunc(f func()) *Status {
-	s := newStatus()
-	go func() {
-		defer s.done()
-		defer func() {
-			if r := recover(); r != nil {
-				if OnPanic != nil {
-					OnPanic(context.Background(), r)
-				}
-			}
-		}()
-		f()
-	}()
-	return s
-}
-
 /******************************* go with value *******************************/
 
 // ValueStatus provides a mechanism to wait for a goroutine that returns a value and an error.
@@ -135,10 +118,11 @@ func GoValue[T any](ctx context.Context, f func(ctx context.Context) (T, error))
 		defer s.done()
 		defer func() {
 			if r := recover(); r != nil {
+				stack := debug.Stack()
 				if OnPanic != nil {
-					OnPanic(ctx, r)
+					OnPanic(ctx, r, stack)
 				}
-				s.err = errors.New("panic occurred")
+				s.err = util.FormatError(nil, "panic: %v\n%s", r, stack)
 			}
 		}()
 		s.val, s.err = f(ctx)