debug

zhangmeng

2020-01-13 af0d6c12d1ae7debb72b30e18d37581cda866137

debug

 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)
        }