我有一个以固定间隔(每分钟)创建一批新作业的进程,我想将它们发送到 kue 以供另一个进程处理。
有时,同一个作业可以分批进行。
如果在前一批中发送的作业在新批次中再次发送时尚未完成,会发生什么情况?
我的理解是它将被视为一项新工作并执行两次。
这是正确的,有没有办法避免这种情况?
一件事是捕获作业complete
事件并遍历排队作业的列表(按照这篇出色的帖子中的说明进行操作)以删除可能的重复项,假设您可以识别它。
我自己从来没有这样做过,如果您遵循这条路线,请注意竞争条件:我想知道是否有可能在您完成遍历未决作业之前安排重复作业(我不知道)。
希望这可以帮助。