chore: pool

go.mod

@@ -1,6 +1,6 @@
 module github.com/xiaojiaoyu100/curlew
 
-go 1.12
+go 1.14
 
 require (
 	github.com/konsorten/go-windows-terminal-sequences v1.0.2 // indirect

worker.go

@@ -34,22 +34,12 @@ func (w *Worker) schedule() {
 			select {
 			case j := <-w.Jobs:
 				{
-					done := make(chan struct{})
-					go func() {
-						defer func() {
-							w.d.WorkerPool <- w
-							done <- struct{}{}
-							if r := recover(); r != nil {
-								w.d.monitor(fmt.Errorf("job crash: job = %#v, err = %#v", 1, r))
-							}
-						}()
-						ctx, cancel := context.WithTimeout(context.TODO(), w.d.MaxJobRunningTimeout)
-						defer cancel()
-						if err := j.Fn(ctx, j.Arg); err != nil {
-							w.d.monitor(fmt.Errorf("job = %#v, err = %#v", j, err))
-						}
-					}()
-					<-done
+					ctx, cancel := context.WithTimeout(context.TODO(), w.d.MaxJobRunningTimeout)
+					if err := j.Fn(ctx, j.Arg); err != nil {
+						w.d.monitor(fmt.Errorf("job = %#v, err = %#v", j, err))
+					}
+					cancel()
+					w.d.WorkerPool <- w
 				}
 			}
 		}