记录一下,方便后续写代码直接使用。
需要注意几点:
在工作中遇到过,由于panic 日志打印不统一在panic监控出现漏报情况。
通过封装panic判断函数,统一日志打印,方便监控添加,避免漏报情况。
package main
import (
"fmt"
"runtime/debug"
"sync"
"time"
)
func COMMON_PANIC_CAPTURE(panicErr interface{}) (bool){ //封装一个panic判断/日志打印函数
if panicErr != nil {
fmt.Printf("PANIC err:%v, stack:%s\n", panicErr, debug.Stack())
return true
}
return false
}
func main() {
var wg sync.WaitGroup
for i := 0; i < 3; i=i+1 {
go func(x int){ //启动go时, 需要注意参数传递
wg.Add(1)
defer func() {
wg.Done()
COMMON_PANIC_CAPTURE(recover())
}()
if x == 2 {
panic(fmt.Sprintf("val:%d", x))
}
}(i)
}
wg.Wait() //等待go结束
time.Sleep(2 * time.Second) //等待go panic日志打印
fmt.Printf("end ok!\n")
}
并发写map panic, 程序无法捕获,可能是go设计的一个问题。
package main
import (
"fmt"
"sync"
"encoding/json"
)
func main() {
res := make(map[string]string)
var wg sync.WaitGroup //group, 内部使用atomic实现计数
var mylock sync.Mutex
for i := 0; i < 4000; i++ {
wg.Add(1)
go func(par int){
defer func() {
wg.Done()
}()
//time.Sleep(3 * time.Second)
tmp := fmt.Sprintf("%d", par %7)
mylock.Lock() //加锁
defer mylock.Unlock() //defer确保解锁
res[tmp] = tmp
}(i)
}
wg.Wait()
resByte, _ := json.Marshal(res)
fmt.Printf("%s\n", string(resByte))
}
原文:https://www.cnblogs.com/xudong-bupt/p/10959110.html