Sidekiq-Unique-jobs Lock只适用于第一个Worker，然后所有挂起的作业都会同时执行？

Question

我可以在队列中挂起3个作业，一旦第一个作业完成，所有剩余的作业都会同时执行。为什么会这样呢？我希望每个worker都获得一个锁，并以序列化的方式让其他作业等待。

class StuffWorker
  include Sidekiq::Worker
  sidekiq_options lock: :until_executed,
                  lock_timeout: 999,
                  lock_info: true,
                  lock_args_method: :lock_args

  def self.lock_args(args)
    [args[0], args[1]]
  end

  def perform(company_id, person_id)
    sleep 10
    logger.info "STARTING IT! at #{DateTime.now.strftime('%H:%M:%S')}"
  end
end

生成以下内容：

JID-ce8c692b5341adb7a24584ab INFO: STARTING IT! at 23:29:52
JID-ce8c692b5341adb7a24584ab INFO: done: 10.728 sec
JID-ca8dac1cbd7cbaf5d87f6096 INFO: STARTING IT! at 23:30:02
JID-463bfe792775e1412d3c0af7 INFO: STARTING IT! at 23:30:02
JID-463bfe792775e1412d3c0af7 INFO: done: 17.754 sec
JID-ca8dac1cbd7cbaf5d87f6096 INFO: done: 14.024 sec

Answer 1

可能，你想要的只是一个运行时锁，而不是队列锁。您必须使用while_executing锁类型https://github.com/mhenrixon/sidekiq-unique-jobs#while-executing。