如何强制Rails ActiveRecord提交事务刷新

是否可以强制ActiveRecord推送/刷新事务(或只是保存/创建)?

我有一个时钟工作者,可以在后台为几个任务工作者创建任务。 问题是,时钟工作者有时会创建一个任务并将其推送给任务工作者,然后才能将时钟工作者信息完全刷新到数据库,从而导致丑陋的竞争状况。

由于产品的体系结构以及如何生成任务,因此使用after_commit并不可行。

简而言之,我需要能够让一个worker创建一个任务并将该任务刷新到db。

ActiveRecord使用#transaction创建一个开始并回滚或提交事务的块。 我相信这会对你的问题有所帮助。 基本上(假设Task是一个ActiveRecord类):

 Task.transaction do new_task = Task.create(...) end BackgroundQueue.enqueue(new_task) 

你也可以直接进入下面的#connection

 Task.connection.commit_db_transaction 

但是,这有点低级,你必须对代码的使用方式充满信心。 #after_commit是最好的答案,即使需要稍微重新调整代码才能使其正常工作。 如果它不能确定,那么这两种方法应该有所帮助。