@@ -70,7 +70,12 @@ func (r *Client) GetAsyncTask(key string) (asyncTask *AsyncTask) {
r.mtx.RUnlock()
}()
- return r.asyncTasks[key]
+ asyncTask, ok := r.asyncTasks[key]
+ if ok {
+ return asyncTask
+ } else {
+ return nil
+ }
}
// SetAsyncTask 设置异步任务
