degrade 降一级,会校验范围
(oneJob task_queue2.OneJob)
| 102 | |
| 103 | // degrade 降一级,会校验范围 |
| 104 | func (t *TaskQueue) degrade(oneJob task_queue2.OneJob) task_queue2.OneJob { |
| 105 | |
| 106 | oneJob.TaskPriority -= 1 |
| 107 | |
| 108 | return t.checkPriority(oneJob) |
| 109 | } |
| 110 | |
| 111 | // Add 放入元素,放入的时候会根据 TaskPriority 进行归类,存在的不会新增和更新 |
| 112 | func (t *TaskQueue) Add(oneJob task_queue2.OneJob) (bool, error) { |
no test coverage detected