554325746@qq.com
2019-07-10 7183fd16c435d2aaf85e24d3608c5c43645ee608
tasktag/tasktag.go
@@ -8,7 +8,6 @@
   "github.com/long/test/util"
)
//var TaskMapLab = make(map[string]*protomsg.TaskLabel)
var TaskMapLab sync.Map
func Init() {
@@ -27,33 +26,31 @@
func GenTaskMap() {
   var tls []protomsg.TaskLabel
   for _, taskSdk := range util.TaskSdks {
      var tl protomsg.TaskLabel
      tl.Taskid = taskSdk.Task.Taskid
        tl.Taskname = taskSdk.Task.Taskname
      for _, sdkinfo := range taskSdk.Sdks {
         tl.Sdkids = append(tl.Sdkids, sdkinfo.Id)
            sdkinfowithtask := new(protomsg.SdkmsgWithTask)
            sdkinfowithtask.Ipcid = sdkinfo.IpcId
            sdkinfowithtask.Sdktype = sdkinfo.SdkType
            sdkinfowithtask.Sdkdata = make([]byte, 1)
            tl.Sdkinfos = append(tl.Sdkinfos, sdkinfowithtask)
      }
      tl.Index = int32(0)
      tls = append(tls, tl)
   }
   GenTasklab(tls)
   TaskMapLab.Range(func(k, v interface{}) bool {
      fmt.Println(k, v)
      return true
   })
   //for key, value := range TaskMapLab {
   //   fmt.Println()
   //   fmt.Println(key, value)
   //}
}
// 从sqlite 接口拿到所有的任务, 每一个任务都有自己的几个算法
//以 taskid 作为key, 对应的算法组合作为 value
func GenTasklab(tasklab []protomsg.TaskLabel) {
   // TaskMapLab = nil
   // TaskMapLab = make(map[string]*protomsg.TaskLabel)
   TaskMapLab.Range(func(key interface{}, value interface{}) bool {
      TaskMapLab.Delete(key)
      return true
@@ -62,6 +59,5 @@
   for _, value := range tasklab {
      pv := value
      TaskMapLab.Store(value.Taskid, &pv)
      //TaskMapLab[value.Taskid] = &pv
   }
}