run.go
@@ -69,7 +69,6 @@ return case id := <-ch: f.mapChanLock.Lock() defer f.mapChanLock.Unlock() for k, v := range f.mapChan { v.life-- if k == id { @@ -81,6 +80,8 @@ delete(f.mapChan, k) } } f.mapChanLock.Unlock() default: time.Sleep(10 * time.Millisecond) }