liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- BaseTask.GetResult中成功返回结果后，结果在任务中会被删除（以免被管理的任务不必要的HOLD住对象）

Browse Source
This commit is contained in:
gazebo
2019-08-29 11:23:17 +08:00
parent 6c805edf92
commit 701da73a6e
1 changed files with 7 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
business/jxutils/tasksch/task.go
View File

@@ -169,6 +169,7 @@ func (t *BaseTask) GetID() string {
return t.ID return t.ID
} }
// 此函数成功返回结果后，结果在任务中会被删除（以免被管理的任务不必要的HOLD住对象）
func (t *BaseTask) GetResult(duration time.Duration) (retVal []interface{}, err error) { func (t *BaseTask) GetResult(duration time.Duration) (retVal []interface{}, err error) {
if t.GetStatus() >= TaskStatusEndBegin { if t.GetStatus() >= TaskStatusEndBegin {
return t.getResult(), t.GetErr() return t.getResult(), t.GetErr()
@@ -279,10 +280,12 @@ func (t *BaseTask) GetNoticeMsg() string {
return t.NoticeMsg return t.NoticeMsg
} }
func (t *BaseTask) getResult() []interface{} { func (t *BaseTask) getResult() (result []interface{}) {
t.locker.RLock() t.locker.Lock()
defer t.locker.RUnlock() defer t.locker.Unlock()
return t.Result result = t.Result
t.Result = nil
return result
} }
func (t *BaseTask) AddBatchErr(err error) { func (t *BaseTask) AddBatchErr(err error) {