Concurrency and Mongoid

Question

В настоящее время я пытаюсь изо всех сил разрабатывать простую веб-игру с использованием рельсов и монгоидов. Я столкнулся с некоторыми проблемами параллелизма, которые я не знаю, как их решить.

Проблема в том, что я не уверен, как атомизировать проверку и принять меры, основанные на ней в Mongoid.

Вот пример из соответствующих частей кода контроллера, чтобы дать вам представление о том, что я пытаюсь сделать:

battle = current_user.battle 
battle.submitted = true 
battle.save 

if Battle.where(opponent: current_user._id, submitted: true, resolving: false).any? 
    battle.update_attribute(:resolving, true) 
    #Resolve turn 

битва между двумя пользователями, но я хочу только одну из потоки для запуска поворота #Resolve. Теперь, если я не отключу оба потока, можно проверить условие один за другим, но прежде чем устанавливать разрешение на истину, поэтому оба заканчивают работу кодом «#Resolve turn».

Я был бы очень признателен за любые идеи о том, как решить эту проблему.

Тем не менее, я все больше чувствую, что синхронизация пользователя таким образом довольно непрактична и что есть лучший способ. Поэтому были бы очень полезны предложения по другим методам, которые могли бы выполнить одно и то же.

Answer 1

Похоже, вы хотите команду mongo findAndModify, которая позволяет вам атомизировать и обновлять строку.

К сожалению Mongoid не появляется, чтобы выставить эту часть Монго API, так что похоже, вам придется опуститься до уровня драйвера для этого один бит:

battle = Battle.collection.find_and_modify(query: {oppenent: current_user._id, ...}, 
              update: {'$set' => {resolving: true}) 

По умолчанию возвращенного объект не включают модификацию сделали, но вы можете включить эту опцию, если вы хотите (пропуск {: новый => верно})

Возвращаемое значение является исходным хэш, если моя память правильно вы можете сделать Battle.instantiate(doc) чтобы вернуть объект Battle.