add chan cache for async

zhangmeng

2020-01-14 c804940ec5bcdcfa0ffe90e03c6866d3bb651416

 run.go

@@ -157,6 +157,12 @@
   }
}

func (f *face) release() {
   if f.handle != nil {
      f.handle.Free()
   }
}

// Run run
func Run(ctx context.Context, i interface{}) {
   s := i.(*face)
@@ -167,8 +173,8 @@
   )
   ipcRcv := sdkhelper.GetIpcAddress(s.shm, s.id+postPull)
   ipcSnd := sdkhelper.GetIpcAddress(s.shm, s.id+postPush)
   chRcv := make(chan []byte)
   chSnd := make(chan sdkstruct.MsgSDK)
   chRcv := make(chan []byte, s.maxChannel)
   chSnd := make(chan sdkstruct.MsgSDK, s.maxChannel)

   rcver := sdkhelper.NewReciever(ipcRcv, chRcv, s.shm, s.fnLogger)
   snder := sdkhelper.NewSender(ipcSnd, chSnd, s.shm, s.fnLogger)