Grail中的并发事务导致数据库过时状态异常

Question

下面是我在api调用上运行的代码。下面的代码位于grails服务中，默认情况下是事务性的。但是，即使在锁定行之后，我也会收到这样的错误：消息：行被另一个事务更新或删除（或未保存的值映射不正确）。数据库中只有一个计划，所以for循环只运行一次。但对api的并发调用会导致错误。请帮我解决这个问题

def updateAllPlans(def user,def percentComplete,def chapterId){
        def plans = Plan.findAllWhere(user:user)
        def chapter = Chapter.findById(chapterId)
        for(def plan:plans){
                def foundChapters = plan.psubject.ptopics.psubtopics.pchapters.chapter.flatten().contains(chapter)
                if(foundChapters){
                    plan.lock()
                    if(percentComplete=='0'){
                        plan.durationViewComplete = plan.durationViewComplete.plusMillis(chapter.duration.getMillisOfSecond())
                        plan.durationViewComplete = plan.durationViewComplete.plusSeconds(chapter.duration.getSecondOfMinute())
                        plan.durationViewComplete = plan.durationViewComplete.plusMinutes(chapter.duration.getMinuteOfHour())
                        plan.durationViewComplete = plan.durationViewComplete.plusHours(chapter.duration.getHourOfDay())
                    }else{
                        plan.durationComplete = plan.durationComplete.plusMillis(chapter.duration.getMillisOfSecond())
                        plan.durationComplete = plan.durationComplete.plusSeconds(chapter.duration.getSecondOfMinute())
                        plan.durationComplete = plan.durationComplete.plusMinutes(chapter.duration.getMinuteOfHour())
                        plan.durationComplete = plan.durationComplete.plusHours(chapter.duration.getHourOfDay())
                    }

                    plan.save(flush:true, failOnError:true)
                }
        }
    }

Answer 1

您只能在计划被读取后锁定它。因此多个线程可以同时读取计划。然后一个线程锁定它并更新它，另一个线程锁定它并更新它。但是它们都是同时读取的，所以两者都读取相同的数据，里面有相同的版本：

thread 1: read plan, with version = 3
thread 2: read plan, with version = 3
thread 1: lock plan
thread 1 : update and save plan. version becomes 4
thread 2 : lock plan
thread 2 : update and save plan. version in memory is 3, but version in database is 4, so an exception is thrown

您需要在阅读时锁定（这是悲观锁定），如文档所示：

def airport = Airport.findByName("Heathrow", [lock: true])

然后，第二个线程必须等待第一个线程保存并提交其事务，然后再读取相同的计划。

然而，这也有悲观锁的所有缺点:吞吐量可能会降低，因为一次只有一个事务可以使用该计划，而这正是乐观锁试图避免的。代价是您可能会得到异常，并且必须处理它们(通过重试、显示错误消息，或者根据情况选择最佳答案)