在 Sidekiq 中更新字段时的竞争条件

【问题标题】：Race condition when updating a field in Sidekiq在 Sidekiq 中更新字段时的竞争条件
【发布时间】：2014-07-11 20:23:59
【问题描述】：

我在 Sidekiq 中有两个线程并发，有一次我在我的一个模型中调用了以下方法：

def update_pending
  update(pending_stats: self.pending_stats + 1)
end

我希望当两个作业都完成时，pending_stats 属性是两个，但它只是一个，即使两个线程都调用该方法。

如何确保两个线程实际上更新为正确的值？

【问题讨论】：

【解决方案1】：

尝试使用increment_counter，这是一个原子操作。

def update_pending increment_counter(:pending_status, 1) 结尾

这将执行以下 SQL：

更新 ... SET pending_status = COALESCE(pending_status, 0) + 1 在哪里 ...

【讨论】：