Ruby on Rails新线程回滚后进度条失效及日志打印异常问题

咱们来逐个拆解你遇到的几个核心问题：

1. raise ActiveRecord::Rollback 后 @pb.failed! 完全无响应 #

这是最直接的逻辑问题：Ruby 里的 raise 语句会立即终止当前代码块的执行流程，所以你写在 raise ActiveRecord::Rollback 之后的 @pb.failed! 永远不会被运行。你需要把进度条状态更新的代码移到 raise 之前，确保回滚操作触发前，进度条状态已经被修改。

另外要注意：ActiveRecord::Rollback 是个特殊异常，它只会触发事务回滚，不会向上冒泡抛出到线程外，但依然会终止事务块内后续所有代码的执行。

2. 无法在 operation 内调用 failed!，事务回滚会同步改变进度条状态 #

看你的代码，operation 里用了 @pb.update_attribute(:current_row, i) —— 如果你的 ProgressBar 是一个 ActiveRecord 模型（即存在对应的数据库表），那这个更新操作是在事务范围内执行的。当事务回滚时，所有在事务内的数据库操作都会被撤销，包括进度条的当前行更新，这就导致进度条状态被“同步回滚”了。

如果你的进度条只是用于前端/控制台实时显示、不需要持久化到数据库，建议改用非持久化的进度条实现（比如 ruby-progressbar gem 的内存对象），这样事务回滚就不会影响它的状态了。

3. 删除 raise 语句后日志仅打印 WORLD 不打印 HELLO #

这是线程执行顺序的问题：

• 你在 import 方法里开启了一个新线程 Thread.new 执行事务逻辑，主线程会立刻跳过线程代码继续往下走，所以先打印了 WORLD。
• 而子线程里的 HELLO 可能还没来得及执行；如果你的代码是在 Rails 请求上下文里运行，主线程（请求线程）结束后，子线程可能会被 Rails 的线程池回收或杀死，导致子线程内的代码没执行完。

如果需要等待子线程执行完毕再继续主线程逻辑，可以在 Thread.new 后调用 join：

thread = Thread.new do
  # 事务逻辑
end
thread.join # 等待子线程执行完毕再继续

修复后的示例代码 #

class Importer
  attr_accessor :file
  def initialize(file)
    @file = file
    @pb = ProgressBar.create
    @pb.number_of_rows(file)
  end
  def import(user)
    thread = Thread.new do
      ActiveRecord::Base.transaction do
        errs = operation(user)
        if errs.any?
          # 先更新进度条状态，再触发回滚
          @pb.failed!
          raise ActiveRecord::Rollback
        end
        Rails.logger.info "HELLO" # 只有无错误时才会打印
      end
    end
    thread.join # 可选：等待子线程完成，根据业务需求调整
    Rails.logger.info "WORLD"
  end
end

def operation(user)
  errs = []
  i = 0
  user.insurances.each do |insurance|
    i += 1
    if insurance.can_have_plan?
      Plan.create(insurance: insurance)
      # 如果用内存进度条，直接更新状态，不受事务回滚影响
      @pb.progress = i # 这里替换为你实际使用的进度条API
    else
      errs << "#{insurance.id} can't have a plan"
    end
  end
  errs
end

几个关键调整点：

• 把 @pb.failed! 移到 raise 之前，确保回滚前状态能更新
• 改用内存进度条替代数据库持久化的进度条（如果适用），避免事务回滚影响进度显示
• 可选添加 thread.join 保证子线程执行完毕，确保 HELLO 能被正常打印

内容的提问来源于stack exchange，提问作者George Morris