在GO里面使用try...catch...finally

func Try(f func(), catch func(interface{}), finally func()) {

    defer func() {

        if finally != nil {

            finally()

        }

    }()

    defer func() {

        if err := recover(); err != nil {

            if catch != nil {

                catch(err)

            } else {

                //loglogic.PFatal(err)//改成你自己的输出代码

            }

        }

    }()

    f()

}

如果想开一个新的协程来跑你的方法时

func GoTry(f func(), catch func(interface{}), finally func()) {
	go Try(f, catch, finally)
}

如果想做一个管理器，对管理你自己开的所有协程，在你关闭时，可以等他们都退出的时候，再退出

//ThreadGo 子协程管理计数，可以等子协程都完成
//用它来管理所有开的协程，需要等这些线程都跑完
type ThreadGo struct {
	Wg  sync.WaitGroup //等待
	Ctx context.Context
	Cal context.CancelFunc
}

func NewThreadGo() *ThreadGo {
	reuslt := new(ThreadGo)
	reuslt.Ctx, reuslt.Cal = context.WithCancel(context.Background())
	return reuslt

}

func (this *ThreadGo) CloseWait() {
	this.Cal()
	this.Wg.Wait()
}

//Go 在当前线程上跑
func (this *ThreadGo) Go(f func(ctx context.Context)) {
	this.Wg.Add(1)
	GoTry(func() {
		f(this.Ctx)
	}, nil, func() {
		this.Wg.Done()
	})
}

//GoTry 在新协程上跑
func (this *ThreadGo) GoTry(f func(ctx context.Context), catch func(interface{}), finally func()) {
	this.Wg.Add(1)
	GoTry(
		func() {
			f(this.Ctx)
		},
		catch,
		func() {
			defer this.Wg.Done()
			if finally != nil {
				finally()
			}
		})
}

//Try 在当前协程上跑
func (this *ThreadGo) Try(f func(ctx context.Context), catch func(interface{}), finally func()) {
	this.Wg.Add(1)
	Try(
		func() {
			f(this.Ctx)
		},
		catch,
		func() {
			defer this.Wg.Done()
			if finally != nil {
				finally()
			}
		})
}