BastenGao's Blog - Web, Rails, Ruby, Java

machinery 同步获取任务结果的小坑


go machinery 写于2020-08-03

下面是 machinery 获取任务执行结果的示例代码

results, err := asyncResult.Get(time.Duration(time.Millisecond * 5))
if err != nil {
  // getting result of a task failed
  // do something with the error
}
for _, result := range results {
  fmt.Println(result.Interface())
}

上面 Get(sleepDuration) 会阻塞调用一直尝试到获取任务结果为止。当任务量巨大的时候,这会导致大量的 redis 查询操作,同时消耗大量的本地 socket 资源,更严重的情况会把本地 socket 资源耗尽。

还好除了同步获取任务结果的方式,还有异步的方式。Signature 可以设置 OnSuccess: []*SignatureOnError: []*Signature 字段,当任务完成后会执行设置的回调任务。这样就完美解决了大量轮询的情况。

comments powered by Disqus
Fork me on GitHub