save 需要把改变的数据保持到 K/V 数据库中,这个没有锁,所以需要在 Sync 中使用,不对外开放
(taskPriority int)
| 389 | |
| 390 | // save 需要把改变的数据保持到 K/V 数据库中,这个没有锁,所以需要在 Sync 中使用,不对外开放 |
| 391 | func (t *TaskQueue) save(taskPriority int) error { |
| 392 | |
| 393 | b, err := t.taskPriorityMapList[taskPriority].ToJSON() |
| 394 | if err != nil { |
| 395 | return err |
| 396 | } |
| 397 | |
| 398 | err = t.center.TaskQueueSave(taskPriority, b) |
| 399 | if err != nil { |
| 400 | return err |
| 401 | } |
| 402 | |
| 403 | return nil |
| 404 | } |
| 405 | |
| 406 | // isExist 是否已经存在,对内,无锁 |
| 407 | func (t *TaskQueue) isExist(jobID string) bool { |
no test coverage detected