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