isExist 是否已经存在,对内,无锁
(jobID string)
| 405 | |
| 406 | // isExist 是否已经存在,对内,无锁 |
| 407 | func (t *TaskQueue) isExist(jobID string) bool { |
| 408 | _, bok := t.taskKeyMap.Get(jobID) |
| 409 | return bok |
| 410 | } |
| 411 | |
| 412 | // IsExist 是否已经存在,对外,有锁 |
| 413 | func (t *TaskQueue) IsExist(jobID string) bool { |