| 31 | } |
| 32 | |
| 33 | func NewTaskQueue(center *cache_center.CacheCenter) *TaskQueue { |
| 34 | |
| 35 | tq := &TaskQueue{queueName: center.GetName(), |
| 36 | log: center.Log, |
| 37 | center: center, |
| 38 | taskPriorityMapList: make([]*treemap.Map, 0), |
| 39 | taskKeyMap: treemap.NewWithStringComparator(), |
| 40 | taskGroupBySeries: treemap.NewWithStringComparator(), |
| 41 | } |
| 42 | for i := 0; i <= taskPriorityCount; i++ { |
| 43 | tq.taskPriorityMapList = append(tq.taskPriorityMapList, treemap.NewWithStringComparator()) |
| 44 | } |
| 45 | tq.read() |
| 46 | |
| 47 | tq.afterRead() |
| 48 | |
| 49 | return tq |
| 50 | } |
| 51 | |
| 52 | func (t *TaskQueue) Close() { |
| 53 | t.center.Close() |