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) } @@ -246,6 +247,7 @@ } } wg.Wait() f.fnLogger("######Wait for All track") } func (f *face) track(wg *sync.WaitGroup, msg *protomsg.SdkMessage, tchan int, out chan<- sdkstruct.MsgSDK) {
