0

我有一个工人试图根据某些条件为照片找到匹配项。每张照片都有一个独特的匹配。我编写了这样的代码：

class PhotoDeliveryWorker
include Sidekiq::Worker

def perform(photo_id)
  photo = Photo.find(photo_id)
  unless photo.match
    matches = Photo.where(some_condition: "some_value")
    match = matches.first

    if match
      # Do something to photo
      photo.match = match

      if photo.save
        match.some_condition = "another_value"
      else
        schedule photo_id
      end
    else
      # Couldn't find a match
      schedule photo_id
    end
  end
end
private
def schedule(photo_id)
  PhotoDeliveryWorker.perform_in 1.hours, photo_id
end
end

如您所见，worker 获取第一个通过条件的模型对象，然后更改match以将其从未来的worker 匹配列表中排除。

问题是当几个工人同时执行时，他们都得到相同的matches列表，因此修改了同一个实体。但我需要为每张照片单独匹配。

我该如何解决？

附加信息：

问：为什么我使用工人？

A：如果找不到匹配项，我需要稍后重试。

问：为什么我使用多线程的 Sidekiq？

A：我需要尽快处理照片。

可能我可以在每个开始时计算当前活跃的工作人员，并参加第 n 场比赛而不是第一次比赛。但是那个解决方案有点味道，不是吗？

更新：

附加问题：我可以在这个问题上使用一些关于 ActiveRecord 锁定的东西吗？我对with_lock所有这些东西都不是很熟悉。

4

1 回答 1

0

解决您的问题的一个非常简单的方法是将工作量分开，这样工人就不会互相干扰。

如果你有 2 个工人，你可以给他们编号并对 id 做一个模数photo.id % 2。这样一来，您只会得到 0 和 1。编号为 0 的工人仅在他的批次上工作，编号为 1 的工人在另一批上工作。通过增加模数，您可以增加任意数量的工人。

于 2013-10-14T08:49:50.930 回答